rocketMq（1）安装和编写生产者

安装途径https://www.imooc.com/article/290089

控制台配置https://www.imooc.com/article/290092

name server:

  Cmd命令框执行进入至‘MQ文件夹\bin’下，然后执行‘start mqnamesrv.cmd’，启动NAMESERVER。成功后会弹出提示框，此框勿关闭。

broker:

Cmd命令框执行进入至‘MQ文件夹\bin’下，然后执行‘start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true’，启动BROKER。成功后会弹出提示框，此框勿关闭。

先启动name server 和 broker服务

再启动控制台

在content-center添加依赖，因为默认2.0.2版本支持的rocketmq是4.4.0，所以我们指定版本为2.0.3，支持4.5.1

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

写配置

#rocketmq
rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: test-group #必须制定一个group

使用RocketMQTemplate

@Autowired
private RocketMQTemplate rocketMQTemplate;

进行信息发送

this.rocketMQTemplate.convertAndSend("add-bonus",
        UserAddBonusMsgDTO.builder()
        .id(share.getUserId())
        .bonus(50)
        .build()
        );//topic 消息体

事先定义一个消息体

@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class UserAddBonusMsgDTO {
    /**
     * 为谁加积分
     */
    private Integer id;
    /**
     * 加多少积分
     */
    private Integer bonus;
}

在成功请求后就可以在控制台看到了