ActiveMQ添加商品接收消息

傷城~ 2022-05-17 08:51 226阅读 0赞

### Destination ###

配置信息

<bean id="test-queue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg name="name" value="test-queue"></constructor-arg>
    </bean>
    <bean id="itemAddTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg name="name" value="item-add-topic"></constructor-arg>
    </bean>

### 添加监听器 ###

ItemAddMessageListener  
监听添加商品事件

public class ItemAddMessageListener implements MessageListener { 
    
        @Autowired
        private SearchItemMapper searchItemMapper;
        @Autowired
        private SolrServer solrServer;
    
        @Override
        public void onMessage(Message message) {
            try {
                // 从消息中取商品id
                TextMessage textMessage = (TextMessage) message;
                String text = textMessage.getText();
                long itemId = Long.parseLong(text);
                // 根据商品id查询数据，取商品信息
                // 等待事务提交
                Thread.sleep(1000);
                SearchItem searchItem = searchItemMapper.getItemById(itemId);
                // 创建文档对象
                SolrInputDocument document = new SolrInputDocument();
                // 向文档对象中添加域
                document.addField("id", searchItem.getId());
                document.addField("item_title", searchItem.getTitle());
                document.addField("item_sell_point", searchItem.getSell_point());
                document.addField("item_price", searchItem.getPrice());
                document.addField("item_image", searchItem.getImage());
                document.addField("item_category_name", searchItem.getCategory_name());
                document.addField("item_desc", searchItem.getItem_desc());
                // 把文档对象写入索引库
                solrServer.add(document);
                // 提交
                solrServer.commit();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
    }

### 配置监听器 ###

ItemAddMessageListener

<bean id="myMessageListener" class="com.taotao.search.listener.MyMessageListener"/>
    
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="test-queue" />
        <property name="messageListener" ref="myMessageListener" />
    </bean>
    <bean id="itemAddMessageListener" class="com.taotao.search.listener.ItemAddMessageListener"/>
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="itemAddTopic" />
        <property name="messageListener" ref="itemAddMessageListener" />
    </bean>