spring boot + rocketMQ--简单的消息发送与接收

1. 环境搭建html

咱们要使用rocketMQ,所以须要使用rocketMQ服务。        安装教程java

以上并无介绍windows下怎么运行,因此讲一下windows的安装方法。git

按照安装教程下载二进制文件,而后解压到任意目录下:github

· 配置环境变量:spring

ROCKETMQ_HOME
E:\rocketMQ\rocketmq-all-4.4.0-bin-release    // 文件解压的路径

完成配置后最好重启下计算机!!!!!!!!不重启可能存在找不到环境变量的错误。apache

· 启动服务:windows

在你安装目录的bin文件夹下打开命令窗口。app

首先启动 namesrvspring-boot

start mqnamesrv.cmd

请勿关闭此命令框ui

启动broker

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

请勿关闭此命令框

假如弹出提示框提示‘错误: 找不到或没法加载主类 xxxxxx’。打开runbroker.cmd,而后将‘%CLASSPATH%’加上英文双引号。保存并从新执行start语句。

若是出现内存不够的错误,请确保机器有足够的运行内存,而后从新启动。

RocketMQ插件部署,这里没研究过,直接参照别人的吧。

========================================================================================

开始正事,官方地址

如下spring boot的版本都是2.1.4.RELEASE

· 搭建生产者(producer),也就是消息发送者

加入pom

<dependency>
   <groupId>org.apache.rocketmq</groupId>
   <artifactId>rocketmq-spring-boot-starter</artifactId>
   <version>2.0.3</version>
</dependency>
## application.properties
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group

新建一个controller来作消息发送:

@RestController
public class SendMessageApi {
    
    @Resource
    private RocketMQTemplate rocketMQTemplate;
    
    @GetMapping(value = "/send/{message}")
    public String echo(@PathVariable String message) {
        // // 往主题test-topic-1直接发送Hello, World!
        // rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");

        // 往主题test-topic-1发送message
        rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload(message).build());

        // // 往主题test-topic-2发送对象,这里对象是本身自定义的dto,须要序列化
        // MessageDto messageDto = new MessageDto();
        // messageDto.setXXX("");
        // ...
        // rocketMQTemplate.convertAndSend("test-topic-2", messageDto);
        System.out.println("消息发送成功.........");
        return message;
    }
    
}

· 搭建消费者(consumer),也就是消息接收者

加入pom

<dependency>
   <groupId>org.apache.rocketmq</groupId>
   <artifactId>rocketmq-spring-boot-starter</artifactId>
   <version>2.0.3</version>
</dependency>
## application.properties
rocketmq.name-server=127.0.0.1:9876
// 接收string类型消息
    @Service
    @RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")
    public class MyConsumer1 implements RocketMQListener<String>{
        public void onMessage(String message) {
            System.out.println("received message: " + message);
        }
    }
    // 接收对象类型的消息
    @Service
    @RocketMQMessageListener(topic = "test-topic-2", consumerGroup = "my-consumer_test-topic-2")
    public class MyConsumer2 implements RocketMQListener<MessageDto>{
        public void onMessage(MessageDto messageDto) {
            System.out.println("received messageDto: " + messageDto.toString());
        }
    }

简单的消息发送与接收搭建完毕。

相关文章
相关标签/搜索