发送异步消息|学习笔记

简介: 快速学习发送异步消息

开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段)发送异步消息】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址:https://developer.aliyun.com/learning/course/702/detail/12377


发送异步消息


与同步消息比较,它传送消息之后不会等 mq 的响应,所以这个时候它发送消息的可靠性就没有同步消息高,异步消息也是可以接收到消息的,可以借用一个回调函数,如果消息需要立刻返回,可以使用异步消息。

异步消息通常用在对响应时间敏感的业务场景,即发送端不能容忍长时间地等待Broker 的响应。

代码如下:

public static void main(String[]args) throws Exception{

//1.剑建消息生产者 producer,并制定生产者组名

DefaultMQProducer  producer=new  DefaultMQProducer (producer Group."group I");

//2.指定Nameserver地址producer. setNamesrvAddr ("192.168.25,135:9876;192.168.25.138:9876");

//3.启动 producer

producer. start();

for(int i=0;i<10;i++){

//4.剑建消息对象,指定主题Topic、Tag和消息体(

/**

*参数一:消息主题 Topic

*参数二:消息 Tag

*参数三:消息内容

*/

Message msg new Message(topic"base", tags:"Tag 1",("Hello world"+i++), get Bytes());

}

//5.发送消息

SendResult  result=producer. send(msg);

//发送状态

Sendstatus  status=result. getSendStatus ();

//消息ID

String msgId=result ggetMsgId();

//消息接受 ID

int queueId=result, getMessageQueue (), getQueueId ();

System. out.printIn("发送状态:"+result+",消息ID"+msgId=",队列"+queueId);l

//6.关闭生产者 producer

Producer.shudown();

public class  AsyncProducer {

public static void main(string[]args) throws Exception{

//实例化消息生产者 Producer

DefaultMQProducer  producer=new DefaultMQ Producer("please rename group group name");

//设置 NameServer 的地址

producer, setNamesrvAddr ("local host:9876");

//启动 Producer 实例

producer, start();

producer, setRetryTimeswhensendAsyncFailed (0);

for (int i= 0;i < 100;i++) {

final int index= i;

//创建消息,并指定 Topic, Tag 和消息体

Message msg=new Message("TopicTest",

"TagA",

"OrderID 188",

"Hello word",getBytes( RemotingHelper .DEFAULT CHARSET));

//send callback接收异步返回结果的回调

producer, send(msg, new  Sendcallback (){

@override

public void onsuccess(Send Result  sendkesult ){

system, out, printf("%-10dOK%s%n", index,

send Result.getMsgId());

}

相关文章
|
人工智能 小程序 大数据
【社区每周】交易组件新增API接口及产品面对面即将开播(5.29-6.2)
【社区每周】交易组件新增API接口及产品面对面即将开播(5.29-6.2)
241 11
|
C++
36.【C/C++ 重载运算符,(全干的无水分)】
36.【C/C++ 重载运算符,(全干的无水分)】
72 0
|
Java Scala 开发者
List 的基本介绍和创建 | 学习笔记
快速学习 List 的基本介绍和创建
List 的基本介绍和创建 | 学习笔记
|
Java 应用服务中间件 开发工具
Springboot实现在线学习管理平台
Springboot实现在线学习管理平台
262 0
Springboot实现在线学习管理平台
|
4天前
|
存储 关系型数据库 分布式数据库
PostgreSQL 18 发布,快来 PolarDB 尝鲜!
PostgreSQL 18 发布,PolarDB for PostgreSQL 全面兼容。新版本支持异步I/O、UUIDv7、虚拟生成列、逻辑复制增强及OAuth认证,显著提升性能与安全。PolarDB-PG 18 支持存算分离架构,融合海量弹性存储与极致计算性能,搭配丰富插件生态,为企业提供高效、稳定、灵活的云数据库解决方案,助力企业数字化转型如虎添翼!
|
15天前
|
弹性计算 关系型数据库 微服务
基于 Docker 与 Kubernetes(K3s)的微服务:阿里云生产环境扩容实践
在微服务架构中,如何实现“稳定扩容”与“成本可控”是企业面临的核心挑战。本文结合 Python FastAPI 微服务实战,详解如何基于阿里云基础设施,利用 Docker 封装服务、K3s 实现容器编排,构建生产级微服务架构。内容涵盖容器构建、集群部署、自动扩缩容、可观测性等关键环节,适配阿里云资源特性与服务生态,助力企业打造低成本、高可靠、易扩展的微服务解决方案。
1312 5
|
2天前
|
监控 JavaScript Java
基于大模型技术的反欺诈知识问答系统
随着互联网与金融科技发展,网络欺诈频发,构建高效反欺诈平台成为迫切需求。本文基于Java、Vue.js、Spring Boot与MySQL技术,设计实现集欺诈识别、宣传教育、用户互动于一体的反欺诈系统,提升公众防范意识,助力企业合规与用户权益保护。