JMS实例(使用ActiveMQ)

别团等shy哥发育

发布于 2023-02-25 16:54:54

6020

发布于 2023-02-25 16:54:54

使用ActiveMQ实现JMS实例

一、下载ActiveMQ：

ActiveMQ官网下载:http://activemq.apache.org/activemq-5015010-release csdn下载：https://download.csdn.net/download/qq_43753724/16579808?spm=1001.2014.3001.5503 下载完成后启动ActiveMQ(双击wrapper.exe或者activemq.bat)

然后，通过http://localhost:8161运行ActiveMQ的管理界面，管理员账号和密码默认为admin/admin,如图：

二、JMS实例

1、创建基于Apache ActiveMQ5的springboot应用

创建Springboot应用ch8_1sender,该应用作为消息发送者

2、配置ActiveMQ的消息代理地址：

在application.properties中，配置ActiveMQ的消息代理地址。

spring.activemq.broker-url=tcp://localhost:61616

3、定义消息

在com.ch.ch8_1sender包下，创建消息定义类MyMessage,该类需要实现MessageCreator接口，并重写接口方法createMessage进行消息定义。

package com.ch.ch8_1sender;
import java.util.ArrayList;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.core.MessageCreator;
public class MyMessage implements MessageCreator{
	@Override
	public Message createMessage(Session session) throws JMSException {
		MapMessage mapm = session.createMapMessage();
		ArrayList<String> arrayList = new ArrayList<String>();
		arrayList.add("陈恒1");
		arrayList.add("陈恒2");
		mapm.setObject("mesg1", arrayList);//只能存Java的基本对象
		mapm.setString("mesg2", "测试消息2");
		return mapm;
	}
}

4、发送消息

在主类Ch81senderApplication中，实现Spring Boot的CommandLineRunner接口，并重写run方法，用于程序启动后的执行代码。在该run方法中，使用JmsTemplate的send方法向目的地mydestination发送MyMessage的消息，也相当于在消息代理上定义了一个叫做mydestination的目的地。

package com.ch.ch8_1sender;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jms.core.JmsTemplate;

@SpringBootApplication
public class Ch81senderApplication implements CommandLineRunner {
    @Autowired
    private JmsTemplate jmsTemplate;
    public static void main(String[] args) {
        SpringApplication.run(Ch81senderApplication.class, args);
    }
    /**
     * 我们这里为了方便操作使用run方法发送消息，
     * 当然完全可以使用控制器通过Web访问
     */
    @Override
    public void run(String... args) throws Exception {
        //new MyMessage()回调接口方法createMessage产生消息
        jmsTemplate.send("mydestination", new MyMessage());
    }
}

5、创建消息接收者

按照步骤1创建Spring Boot应用ch8_1receive，该应用作为消息接收者，并按照步骤2配置ch8_1receive的ActiveMQ的消息代理地址。

6、定义消息监听器接收消息

在应用ch8_1receive的com.ch.ch8_1receive包中，创建消息监听器类ReceiverMsg。在该类中使用@JmsListener注解不停地监听目的地mydestination是否有消息发送过来，如果有就获取消息。

package com.ch.ch8_1receive;
import java.util.ArrayList;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
@Component
public class ReceiverMsg {
	@JmsListener(destination="mydestination")
	public void receiverMessage(MapMessage mapm) throws JMSException {
		@SuppressWarnings("unchecked")
		ArrayList<String> arrayList = (ArrayList<String>)mapm.getObject("mesg1");
		System.out.println(arrayList);
		System.out.println(mapm.getString("mesg2"));
	}
}