ActiveMQ在项目中的使用

作者: Dream_wdl | 来源:发表于2018-08-27 08:26 被阅读0次

ActiveMQ在项目中的使用
activeMQ实例在项目中的运用
ActiveMQ RabbitMQ RocketMQ KafKa
【JAVA】ActiveMQ
ActiveMQ嵌入Tomcat
第三课 ActiveMQ在项目中的使用
kafka的安装与使用
ActiveMq伪集群设置
SpringBoot集成ActiveMQ
第二课 ActiveMQ与Spring的整合使用

分析：
在后台每次添加或修改文章的时候，发送一个消息，内容为新添加或修改的文章id，solr服务层接收到消息后取出文章id，根据id去数据库查询文章信息，然后更新索引库，从而达到同步效果。修改的话同时还要删除redis缓存，如果不使用ActiveMQ，同时做这许多事会导致客户端响应慢。

配置文件中：配置连接工厂生产者，目的地。

<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.25.128:61616" />
</bean>

<bean id="connectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory">

<property name="targetConnectionFactory" ref="targetConnectionFactory" />
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

<property name="connectionFactory" ref="connectionFactory" />
</bean>

<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg>
<value>spring-queue</value>
</constructor-arg>
</bean>

<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg value="itemAddTopic" />
</bean>
Controller:

@Controller
public class HomeController {
@Autowired
private JmsTemplate jmsTemplate;
//注入主题目的地（发布/订阅模式）
@Autowired
private Destination topicDestination;
@RequestMapping("/")
public ModelAndView home() throws IOException, SolrServerException {

    jmsTemplate.send(topicDestination, new MessageCreator() {

        @Override
        public Message createMessage(Session session) throws JMSException {
            TextMessage message = session.createTextMessage(99+"");
            return message;
        }
    });

 
    return null;
}

}

接收消息，实现solr索引库文章信息与数据库文章信息同步

配置文件中:配置连接工厂，目的地，自定义消息监听器和消息监听容器

<!--这个是队列目的地，点对点的 -->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg>
        <value>spring-queue</value>
    </constructor-arg>
</bean>
<!--这个是主题目的地，一对多的 -->
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg value="itemAddTopic" />
</bean>

<bean id="itemAddMessageListener" class="cn.e3mall.search.message.ItemAddMessageListener"></bean>
<!-- 监听商品添加消息，同步索引库 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destination" ref="topicDestination" />
    <property name="messageListener" ref="itemAddMessageListener" />
</bean>

自定义文章修改消息监听器

package com.neusoft.util;

import org.springframework.stereotype.Component;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**

Created by Administrator on 2018/8/15.
*/

public class ItemAddMessageListener implements MessageListener {

public void onMessage(Message message) {
    //从消息中取商品id
    TextMessage textMessage = (TextMessage) message;
    try {
        String text = textMessage.getText();
        Long itemId = Long.parseLong(text);
        System.out.println("onMessageonMessageonMessageonMessageonMessage"+itemId);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

}