ActiveMQ在项目中的使用
分析：
在后台每次添加或修改文章的时候，发送一个消息，内容为新添加或修改的文章id，solr服务层接收到消息后取出文章id，根据id去数据库查询文章信息，然后更新索引库，从而达到同步效果。修改的话同时还要删除redis缓存，如果不使用ActiveMQ，同时做这许多事会导致客户端响应慢。
配置文件中：配置连接工厂生产者，目的地。
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索引库文章信息与数据库文章信息同步
配置文件中:配置连接工厂，目的地，自定义消息监听器和消息监听容器
spring-queue
自定义文章修改消息监听器
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 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();
}
}
【ActiveMQ在项目中的使用】}
