Spring整合 RocketMQ

Spring整合RocketMQ非常简单，只需将Spring作为RocketMQ消息消费者、消息生产者的Bean容器，配置文件如代码清单11-15所示。

代码清单11-15　配置文件

<bean id="mqProducer"
      class="persistent.prestige.web.base.mq.rocketmq.MqProducer" init-method="init" destroy-method="destroy">
    <property name="producerGroup">
        <value>MyProducerGroup</value>
    </property>
    <property name="namesrvAddr">
        <value>192.168.56.166:9876</value>
    </property>
</bean>
<bean id="mqConsume" class="persistent.prestige.web.base.mq.rocketmq.MqConsume" init-method="init" destroy-method="destroy">
    <property name="consumerGroup">
        <value>MyConsumerGroup</value>
    </property>
    <property name="namesrvAddr">
        <value>192.168.56.166:9876</value>
    </property>
</bean>