API和注解列表

    API 类型 发送端/消费端 说明
    RocketMQTemplate API 发送端 发送端负责发送消息和API，他与@Resource注解一同使用，进行对象的声明和实例化
    RocketMQTransactionListener 注解 发送端 修饰事务回查Listener
    TransactionListener API 消费端 事务回查Listener接口，实现本地是物质性方法和本地事务回查方法
    RocketMQMessageListener 注解 消费端 修饰消息消费Listener
    RocketMQListener API 消费端 消息消费Listener接口，实现消费消息的处理逻辑的方法
    RocketMQPushConsumerLifecycleListener APi 消费端 该接口用来实现Push方法消费时，消费者的信息配置，如消费时间和消费位点方式

    @RocketMQMessageListener

    1. 在监听器上通过注解配置，需要监听的topic和指定消费者的组名;
    3. 1.rocket监听器注解，用于监听topic中的消息
    4. 2.注解属性
    5.     topic 主题名称，必须与生产者发送消息时候指定的主题名称一致
    6.             例如：发消息
    7.              template.convertAndSend("topic_email","...");
    8.             这里如果要收到消息，topic属性值是topic_email
    9.             consumerGroup消费者分组； 一般情况下，我们建议一个消费者分组，仅消费一个Topic。
    10.             分组好处： A 每个消费者分组职责单一，只消费一个Topic。
    11.             B 每个消费者分组是独占一个线程池，这样能够保证多个Topic隔离在不同线程池，保持隔离性
    12.                 从而避免一个Topic消费很慢，影响到另外的Topic的消费
    13.                 TIPS： 这里的分组名称可以随便给，唯一即可。如：baseGroup，uesrGroup都可以
    16.   /**
    17.  * @RocketMQMessageListener
    18.  * 1、修饰RocketMQ中消息监听器类
    19.  * 2、注解属性
    20.  *   topic 指定主题名称，消费哪一类消息。要与发送消息指定的主题名称一致。
    21.  *   consumerGroup 消费者组名称，相同名词的消费者作为一个组。分组后可以实现消息的负载均衡。
    22.  *                 比如：同一个组内2个消费者，消费者A消费了消息，B就不会再消费消息。
    23.  */
    24. @Component
    25. @RocketMQMessageListener(topic = "testTopic",consumerGroup = "baseGroup")
    26. public class MyMessageListener implements RocketMQListener<String> {
    27.     @Override
    28.     public void onMessage(String message) {
    29.         System.out.println("消息内容：" + message);
    30.     }
    31. }