rocketmq 发送/接收消息简单demo
(1)配置连接ip
producer.setNamesrvAddr("192.168.1.133:9876");
(2)发送消息 TestProducer.java
public class TestProducer {
public static void main(String[] args) throws MQClientException, InterruptedException {
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
producer.setNamesrvAddr("192.168.1.133:9876");
producer.start();
long start=System.currentTimeMillis();
for (int i = 0; i < 10; i++)
try {
{
Message msg = new Message("TopicTest1",
"TagA",
"key113",
("Hello world "+i).getBytes(RemotingHelper.DEFAULT_CHARSET));
SendResult sendResult = producer.send(msg);
System.out.printf("%s%n", sendResult);
} catch (Exception e) {
e.printStackTrace();
}
long end=System.currentTimeMillis();
System.out.println(end-start+"**");
producer.shutdown();
}
}
(3)接收消息(Push) ConsumerTest.java
public class ConsumerTest {
public static void main(String[] args) throws InterruptedException, MQClientException {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ProducerGroupName_C");
consumer.setNamesrvAddr("192.168.1.133:9876");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.subscribe("TopicTest1", "*");
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
ConsumeConcurrentlyContext context) {
System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
System.out.println(new String(msgs.get(0).getBody()));
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
consumer.start();
System.out.printf("Consumer Started.%n");
}
}
分享到:
相关推荐
RocketMQ消息队列demo,输入IP端口,就可以对消息队列进行操作,发布消息,订阅消息。
国民MCU SPI主发送 SPI从接受 DEMO工程。 SDA(MOSI ) CS CLK SPI 单线发送/接收模式
该资源为在购买了阿里云中间件产品rocketmq消息队列之后,使用的连接rocketmq的demo工程,该程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例,同时提供tcp连接的程序。
1、demo带串口发送指令,主要是电子秤开发 2、发送指令后,同时接受数据到变量里 3、同时也封装好串口通信的类 好的话 给个赞吧,一直找不到C++ 的发送同时接受的demo,最后自己写了
这个demo实现了Android蓝牙开发,创建客户端,服务端。并实现互发消息,接收消息
微信HOOK(windows版)-非协议c#Demo,实现了收发信息,群消息管理,添加群成员,无痕清粉等功能。 https://www.showdoc.cc/491000845082710?page_id=2886334713210446
C#利用windows的API发送和接收消息Demo, 实现一个两个程序之间消息的通信,一个发送,另一个程序自动接收。 本代码测试全通过 .
很全的rocket包及安装详细说明附加demo示例。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。...
Tibco rv sender && Receiver .net3.5 .net4.0
初学者可以来学习一下,rocketMQ的简单的小demo 简单易懂
java编写的RocketMQ入门demo,maven 更新依赖,可直接运行Producer和Consumer 简单进行测试
springboot 整合 rocketmq实例代码
springboot1.5.10.RELEASE集成rocketmq4.3.1消息服务demo,多个消费者多监听
一个基于串口的手机短信发送/接收程序;Demo很简单,是以异步方式读写串口的;在对话框初始化中修改串口的配置参数正确后,能100 的正常发送/接收短信
简单的广播收发demo,适合初学者,简单清晰明了。自定义
springboot集成activemq实现消息接收demo
基恩士激光位移传感器C#/C++/VB.net的demo 很难找 找了很久才找到
Android 广播接收 发送 Broadcast demo
RocketMQ原生API使用 SpringBoot整合RocketMQ SpringCloudStream整合RocketMQ
springboot集成消息队列实现发送与接收demo; 包含activemq rocketmq kafka等