📌  相关文章
📜  Spring和JMS集成

📅  最后修改于: 2020-12-04 08:53:55             🧑  作者: Mango

Spring和JMS集成

要将spring与JMS集成，您需要创建两个应用程序。

  • JMS接收器应用程序
  • JMS Sender应用程序

为了使用spring创建JMS应用程序，我们使用Apache的Active MQ Server创建队列。

让我们看一下将spring应用程序与JMS集成的简单步骤：

所需的Jar文件

1)您需要添加spring core ， spring misc ， spring aop ， spring j2ee和spring persistence core jar文件。

下载Spring的所有jar文件，包括aop，mvc，j2ee，remoting，oxm等。

2)加入位于ActiveMQ的目录中activemqall5.9.jar文件。

在ActiveMQ Server中创建队列

下载Active MQ服务器下载Active MQ

双击位于Apache的ActiveMQ的-5.9.1-BIN \ Apache的ActiveMQ的-5.9.1 \ BIN \ Win64平台或win32目录里面的activemq.bat文件。

现在，activemq服务器控制台将打开。

通过http：// localhost：8161 / admin / url访问activemq服务器的管理控制台。

现在，单击“队列”链接，在文本字段中写入myqueue ，然后单击“创建”按钮。

1)JMS接收器应用程序

让我们看一下将spring应用程序与JMS集成的简单步骤：

  • MyMessageListener.java
  • TestListener.java
  • applicationContext.xml
package com.javatpoint;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class MyMessageListener implements MessageListener{
    @Override
    public void onMessage(Message m) {
        TextMessage message=(TextMessage)m;
        try{
            System.out.println(message.getText());
        }catch (Exception e) {e.printStackTrace();    }
    }
}

package com.javatpoint;
import org.springframework.context.support.GenericXmlApplicationContext;
public class TestListener {
public static void main(String[] args) {
    GenericXmlApplicationContext ctx=new GenericXmlApplicationContext();
    ctx.load("classpath:applicationContext.xml");
    ctx.refresh();
    
    while(true){}
}
}

2)JMS Sender应用程序

让我们看一下创建JMS Sender应用程序的文件：

  • MyMessageSender.java
  • TestJmsSender.java
  • applicationContext.xml
package com.javatpoint;
import javax.jms.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

@Component("messageSender")
public class MyMessageSender {
@Autowired
private JmsTemplate jmsTemplate;
public void sendMessage(final String message){
    jmsTemplate.send(new MessageCreator(){

        @Override
        public Message createMessage(Session session) throws JMSException {
            return session.createTextMessage(message);
        }
    });
}
}

package com.javatpoint;
import org.springframework.context.support.GenericXmlApplicationContext;
public class TestJmsSender {
public static void main(String[] args) {
    GenericXmlApplicationContext ctx=new GenericXmlApplicationContext();
    ctx.load("classpath:applicationContext.xml");
    ctx.refresh();
    
    MyMessageSender sender=ctx.getBean("messageSender",MyMessageSender.class);
    sender.sendMessage("hello jms3");
    
}
}