溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié))

發(fā)布時間：2020-10-06 05:00:20 來源：腳本之家 閱讀：184 作者：朽木要自雕 欄目：編程語言

實(shí)現(xiàn)消息隊(duì)列的兩種方式

Apache ActiveMQ官方實(shí)例發(fā)送消息

直接在Apache官網(wǎng)http://activemq.apache.org/download-archives.html下載ActiveMQ源碼

下載解壓后拿到j(luò)ava代碼實(shí)例

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié)) 

然后倒入IDE

如下：

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié)) 

請認(rèn)真閱讀readme.md文件，大致意思就是把項(xiàng)目打成兩個jar包，然后啟動服務(wù)，然后同時運(yùn)行打的兩個jar包，然后就能看到具體的調(diào)用信息。打jar包時直接利用maven打就行了，不用修改代碼。

啟動服務(wù)：

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié)) 

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié))

利用Spring消息模板發(fā)送消息

Spirng對Apache ActiveMQ提供了很好的支持

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié)) 

生成者代碼：

package com.jms.service.impl;

import com.jms.service.ProducerService;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.jms.Destination;

/**
 * 發(fā)送消息
 */
@Service
public class ProducerServiceImpl implements ProducerService {

 @Resource
 private JmsTemplate jmsTemplate;

 public void sendMessage(Destination destination, String msg) {
  System.out.println("向隊(duì)列"+destination+"發(fā)送消息");
  jmsTemplate.convertAndSend(destination,msg);
 }

 public void sendMessage(String msg) {
  System.out.println("向隊(duì)列"+jmsTemplate.getDefaultDestination().toString()+"發(fā)送消息");
  jmsTemplate.convertAndSend(msg);
 }
}

消費(fèi)者代碼：

package com.jms.service.impl;

import com.jms.service.CustomerService;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;

@Service
public class CustomerServiceImpl implements CustomerService {

 @Resource
 private JmsTemplate jmsTemplate;
 /**
  * 接收消息
  * @param destination
  */
 public void receive(Destination destination) {

  TextMessage textMessage = (TextMessage) jmsTemplate.receive(destination);
  try {
   System.out.println("從隊(duì)列》"+destination.toString()+"成功獲取消息》"+textMessage.getText());
  } catch (JMSException e) {
   e.printStackTrace();
  }

 }
}

Spring配置代碼

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:mvc="http://www.springframework.org/schema/mvc"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/context
  http://www.springframework.org/schema/context/spring-context.xsd
  http://www.springframework.org/schema/mvc
  http://www.springframework.org/schema/mvc/spring-mvc.xsd
  ">

 <!-- 啟動包掃描功能，以便注冊帶有@Controller、@Service、@repository、@Component等注解的類成為spring的bean -->
 <context:component-scan base-package="com.jms.service"> </context:component-scan>

 <!-- 配置根視圖 -->
 <!--<mvc:view-controller path="/" view-name="index"/>-->

 <!--啟用注解-->
 <mvc:annotation-driven />

 <!-- 視圖層配置 -->
 <!--<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">-->
  <!--<property name="prefix" value="/WEB-INF/view/"/>-->
  <!--<property name="suffix" value=".jsp"/>-->
 <!--</bean>-->


 <!-- 配置JMS連接工廠 -->
 <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
  <property name="brokerURL" value="tcp://localhost:61616" />
 </bean>

 <!-- 定義消息隊(duì)列（Queue） -->
 <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
  <!-- 設(shè)置消息隊(duì)列的名字 -->
  <constructor-arg>
   <value>queue1</value>
  </constructor-arg>
 </bean>

 <!-- 配置JMS模板（Queue），Spring提供的JMS工具類，它發(fā)送、接收消息。 -->
 <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
  <property name="connectionFactory" ref="connectionFactory" />
  <property name="defaultDestination" ref="queueDestination" />
  <property name="receiveTimeout" value="10000" />
 </bean>
</beans>

測試代碼

package com.jsm.test;

import com.jms.service.CustomerService;
import com.jms.service.ProducerService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import javax.jms.Destination;

/**
 * 消息隊(duì)列測試類
 */
public class JmsTest {


 @Test
 public void producerTest(){

  ClassPathXmlApplicationContext springContext = new ClassPathXmlApplicationContext(new String[]{"classpath:spring-core.xml"});
  ProducerService producerService = (ProducerService)springContext.getBean("producerServiceImpl");
  CustomerService customerService = (CustomerService)springContext.getBean("customerServiceImpl");

  Destination destination = (Destination)springContext.getBean("queueDestination");
  producerService.sendMessage("測試消息隊(duì)列");
  customerService.receive(destination);
 }
}

測試結(jié)果

java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié)) 

代碼地址

https://github.com/wahnn/SpringJMS
https://gitee.com/wahnn/SpringJMS

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手