admin 管理员组

文章数量: 1184232


2024年2月29日发(作者：电脑进程管理工具)

rocketmq java收发示例

以下是一个简单的Java示例，演示如何使用RocketMQ发送和接收消息：

发送消息：

```java

import tMQProducer;

import e;

public class Producer {

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

// 创建消息生产者Producer，并设置生产者组名为"ProducerGroupName"

DefaultMQProducer producer = new

DefaultMQProducer("ProducerGroupName");

// 设置NameServer地址

esrvAddr("localhost:9876");

// 启动Producer实例

();

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

// 创建消息对象，并设置Topic，Tag和消息体

Message msg = new Message("TopicTest", "TagA", "OrderID188",

"Hello world".getBytes(T_CHARSET));

// 发送消息到一个Broker服务器

try {

(msg);

} catch (Exception e) {

tackTrace();

}

}

// 如果不再发送消息，关闭Producer实例。

wn();

}

}

```

接收消息：

```java

import tMQPushConsumer;

import

eConcurrentlyContext;

import

eConcurrentlyStatus;

import

eListenerConcurrently;

import eExt;

import ;

public class Consumer {

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

// 创建消费者实例，并设置消费者组名为"ConsumerGroupName"

DefaultMQPushConsumer consumer = new

DefaultMQPushConsumer("ConsumerGroupName");

// 设置NameServer地址

esrvAddr("localhost:9876");

// 订阅一个或者多个Topic，以及Tag来过滤需要消费的消息。

ibe("TopicTest", "*");

// 注册回调实现类来处理从broker服务器发送过来的消息。

erMessageListener((MessageListenerConcurrently)

(msgs, context) -> {

("%s Receive New Messages: %s %n",

tThread().getName(), msgs);

return E_SUCCESS;

});

// 启动消费者实例。

();

}

}

```


本文标签： 消息 设置 发送 实例 消费者

版权声明：本文标题：rocketmq java收发示例 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.roclinux.cn/b/1709214865a540601.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。