單向發送消息

這種方式主要用在不特別關心發送結果的場景，例如日志發送。

package com.leon.mq.rocketmq.base.producer;import org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.common.message.Message;import java.util.concurrent.TimeUnit;/*** 發送單向消息*/ public class OneWayProducer {public static void main(String[] args) throws Exception, MQBrokerException {//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 < 3; i++) {//4.創建消息對象，指定主題Topic、Tag和消息體/*** 參數一：消息主題Topic* 參數二：消息Tag* 參數三：消息內容*/Message msg = new Message("base", "Tag3", ("Hello World，單向消息" + i).getBytes());//5.發送單向消息producer.sendOneway(msg);//線程睡1秒TimeUnit.SECONDS.sleep(5);}//6.關閉生產者producerproducer.shutdown();} }

?

總結

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

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