我们都知道 rocketmq 发送消息有 3 中方式:
1、同步
     同步发送消息,是可以拿到消息结果的,
  
 2、oneway 方式
     这种方式最适合发送日志啦,比如,最求速度的。可以采取这种方式。

3、异步
     这种方式有点误解了,其实这个也是返回结果的。
     
     
     可以从第二种截图中看出,这里需要实现回调接口的。

其实呢,不管是同步,还是异步,broker 都会 response 相关的信息回来的。只是异步需要实现接口而已罢了。
下面的代码我 copy ons 上面的代码的:
public static void main(String[] args) {
Properties properties = new Properties();
properties.put(PropertyKeyConst.AccessKey, “DEMO_AK”);// AccessKey
阿里云身份验证,在阿里云服务器管理控制台创建
properties.put(PropertyKeyConst.SecretKey, “DEMO_SK”);// SecretKey
阿里云身份验证,在阿里云服务器管理控制台创建
properties.put(PropertyKeyConst.ProducerId, “DEMO_PID”);//您在控制台创建的Producer ID
properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis,
“3000”);//设置发送超时时间,单位毫秒
Producer producer = ONSFactory.createProducer(properties);
// 在发送消息前,必须调用start方法来启动Producer,只需调用一次即可。
producer.start();
Message msg = new Message(
// Message Topic
“TopicTestMQ”,
// Message Tag,可理解为Gmail中的标签,对消息进行再归类,方便Consumer指定过滤条件在MQ服务器过滤
“TagA”,
// Message Body,任何二进制形式的数据,MQ不做任何干预,需要Producer与Consumer协商好一致的序列化和反序列化方式
“Hello MQ”.getBytes());
// 设置代表消息的业务关键属性,请尽可能全局唯一。以方便您在无法正常收到消息情况下,可通过MQ控制台查询消息并补发。
// 注意:不设置也不会影响消息正常收发
msg.setKey(“ORDERID_100”);
// 异步发送消息, 发送结果通过callback返回给客户端。
producer.sendAsync(msg, new SendCallback() {
@Override
public void onSuccess(final SendResult sendResult) {
// 消费发送成功
System.out.println(“send message success. topic=” + sendResult.getTopic() +
“, msgId=” + sendResult.getMessageId());
}
@Override
public void onException(OnExceptionContext context) {
// 消息发送失败
System.out.println(“send message failed. topic=” + context.getTopic() + “,
msgId=” + context.getMessageId());
}
});
// 在callback返回之前即可取得msgId。
System.out.println(“send message async. topic=” + msg.getTopic() + “, msgId=”
+ msg.getMsgID());
    没
应用退出前,销毁Producer对象。注意:如果不销毁也
有问题
    producer.shutdown();

    rocketmq 发送 异步消息和 ons 差不多的啦,在此不再举例子啦

技术
©2019-2020 Toolsou All rights reserved,
排序(一)冒泡排序法一文揭秘阿里、腾讯、百度的薪资职级大数据告诉你,中国女人有多累年薪20万属于什么水平?答案让人扎心!面试的时候突然遇到答不上的问题怎么办?SpringBoot实践(五):mybatis-plus中的BaseMapper,Iservice和ServiceImpl这些歌,程序员千万万万万别听!python中解决字典写入列表的问题中台透彻讲解GDOI2019 游记