测试rocketmq简单的使用

1.RocketMQ--阿里巴巴推出的消息队列 1.主要组成结构： 1.producer cluster 生产者群 2.consumer cluster 消费者群 3.name server 名称服务器，类似于注册中心 4.broker 消息服务器。定时将自己的状态发送到nameServer，默认10秒一次，超过2分钟该broker会被认为失效 2.三种消息发送方式： 1.同步消息：生产者向broker发送消息，执行API后同步等待，直到broker返回消息发送结果。 2.异步消息：生产者向broker发送消息时指定消息发送成功或异常的回调方法，执行API后立即返回，消息发送成功 或发送异常后的回调方法会在另一个线程中执行。 3.单向消息：生产者向broker发送消息，执行API后直接返回，不等待broker发送消息的结果。 3.入门使用： 1.导入依赖 2.创建生产者并配置服务端口号以及服务名、RocketMQ的nameServer地址、生产者分组 3.在生产者中任意类中创建RocketMQTemplate实例对象，调用其不同方法以不同的方式发送消息。 4.创建消费并配置服务端口号、服务名、RocketMQ的nameServer地址 5.创建消费者信息监听类并实现接口RocketMQListener<T> 6.并使用注解标注监听类，并标注监听的主题topic和消费者组，如： @RocketMQMessageListener(topic = "my-topic",consumerGroup = "demo-consumer-group") 7.实现接口方法，也就是监听到消息执行的方法 *延迟消息+消费重试