消息發(fā)送和接收演示

接下來我們使用Java代碼來演示消息的發(fā)送和接收

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.2</version> </dependency>

發(fā)送消息

消息發(fā)送步驟:

1. 創(chuàng)建消息生產(chǎn)者, 指定生產(chǎn)者所屬的組名

2. 指定Nameserver地址

3. 啟動(dòng)生產(chǎn)者

4. 創(chuàng)建消息對(duì)象，指定主題、標(biāo)簽和消息體

5. 發(fā)送消息

6. 關(guān)閉生產(chǎn)者

package com.leon.test;import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.spring.core.RocketMQTemplate;public class RocketMQSendMessageTest {//發(fā)送消息public static void main(String[] args) throws Exception {//1.創(chuàng)建消息生產(chǎn)者,并且設(shè)置生產(chǎn)組名DefaultMQProducer producer = new DefaultMQProducer("myproducer-group");//2 為生產(chǎn)者設(shè)置NameServer的地址producer.setNamesrvAddr("192.168.109.131:9876");//3 啟動(dòng)生產(chǎn)者producer.start();//4 構(gòu)建消息對(duì)象,主要是設(shè)置消息的主題 標(biāo)簽 內(nèi)容Message message = new Message("myTopic", "myTag", ("Test RocketMQ Message").getBytes());//5 發(fā)送消息 第二個(gè)參數(shù)代表超時(shí)時(shí)間SendResult result = producer.send(message, 10000);System.out.println(result);//6 關(guān)閉生產(chǎn)者producer.shutdown();} }

?

總結(jié)

以上是生活随笔為你收集整理的Java实现消息发送的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。