發送同步消息

這種可靠性同步地發送方式使用的比較廣泛，比如：重要的消息通知，短信通知。

package com.leon.mq.rocketmq.base.producer;import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.SendStatus; import org.apache.rocketmq.common.message.Message;import java.util.concurrent.TimeUnit;/*** 發送同步消息*/ public class SyncProducer {public static void main(String[] args) throws Exception {//1.創建消息生產者producer，并制定生產者組名DefaultMQProducer producer = new DefaultMQProducer("group1");//2.指定Nameserver地址producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");//3.啟動producerproducer.start();for (int i = 0; i < 10; i++) {//4.創建消息對象，指定主題Topic、Tag和消息體/*** 參數一：消息主題Topic* 參數二：消息Tag* 參數三：消息內容*/Message msg = new Message("springboot-mq", "Tag1", ("Hello World" + i).getBytes());//5.發送消息SendResult result = producer.send(msg);//發送狀態SendStatus status = result.getSendStatus();System.out.println("發送結果:" + result);//線程睡1秒TimeUnit.SECONDS.sleep(1);}//6.關閉生產者producerproducer.shutdown();} }

?

總結

以上是生活随笔為你收集整理的发送同步消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。