1.JMS消息的发送
import java.io.Serializable;
import java.util.HashMap;
import java.util.Iterator;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.QueueConnection;
import javax.jms.Session;
import com.sun.messaging.ConnectionConfiguration;
import com.sun.messaging.ConnectionFactory;
import com.sun.messaging.Queue;
/**
* JMS发送工具类
* @author owner
*
*/
public class JMSUtil {
/**
* 发送Queue消息
*
* @param content
* 消息传递内容
* @param queueName
* 消息对象传送序列名称.如:MQtest
*
*/
public static void send(Object content,String queueName) {
try {
ConnectionFactory connectionFactory = null;
QueueConnection connection = null;
Session session = null;
MessageProducer producer = null;
Message message = null;
try {
/** 建立消息服务器连接 */
connectionFactory = new ConnectionFactory();
/**服务器地址*/
String jmsServer = "localhost:8080";
/**用户名称*/
String jmsUser = "admin";
/**密码*/
String jmsPassword ="admin";
connectionFactory.setProperty("imqAddressList", jmsServer);
connectionFactory.setProperty(ConnectionConfiguration.imqDefaultUsername, jmsUser);
connectionFactory.setProperty(ConnectionConfiguration.imqDefaultPassword,jmsPassword);
/**创建queue点对点模式连接。topic是发布模式*/
connection = connectionFactory.createQueueConnection();
/**通过服务连接创建会话*/
session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//AUTO_ACKNOWLEDGE自动提示
Destination destination = null;
try {
/**通过序列名称创建会话目标对象*/
destination = new Queue(queueName);
} catch (Throwable throwable) {
return;
}
/**创建消息制造者:用消息制造者来发送消息*/
producer = session.createProducer(destination);
/**开始连接消息服务器*/
connection.start();
// 字符串类型内容
if (content instanceof String) {
/**如果消息传递内容为字符串则通过会话创建文本消息*/
message = session.createTextMessage(content.toString());
}
// hash表型内容
else if (content instanceof HashMap) {
/**如果消息传递内容为HashMap则通过会话创建Map消息*/
HashMap contentMap = (HashMap) content;
MapMessage mm = session.createMapMessage();
/**把要发送的map内容转入会话创建的消息Map中*/
Iterator it = contentMap.keySet().iterator();
boolean isDifficulty = false;//判断是Map中值是否是对象:true为对象
while (it.hasNext()) {
String name = it.next().toString();
Object o = contentMap.get(name);
/**该会话创建的map消息中只存储值为String的字符串,如果是对象,则会创建值为object的对象消息*/
if (o != null && !(o instanceof String)) {
isDifficulty = true;
break;
}
if (o == null) {
mm.setString(name, "");
} else {
mm.setString(name, o.toString());
}
}
if (isDifficulty) {
/**如果是Map中存的值为非字符串则创建Object消息*/
message = session.createObjectMessage((Serializable) content);
} else {
message = mm;
}
}
// 其它类型内容
else {
/**如果消息内容不是map也不是字符串则直接创建一个Object类型消息*/
message = session
.createObjectMessage((Serializable) content);
}
/**消息制造者发送消息*/
producer.send(message);
}
// JMS链接例外,记录例外日志,并抛出错误信息
catch (JMSException ex) {
ex.printStackTrace();
} finally {
try {
/**关闭连接*/
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
} catch (Throwable ex1) {
ex1.printStackTrace();
}
}
}
2.JMS消息的接收
第一步:创建mq连接工厂的实现。用于设置工厂构建连接地址
package com.test.jms;
import javax.jms.Connection;
import javax.jms.JMSException;
import com.sun.messaging.ConnectionConfiguration;
import com.sun.messaging.ConnectionFactory;
public class OpenMqConnectionFactory implements javax.jms.ConnectionFactory{
private ConnectionFactory connectionFactory;
public OpenMqConnectionFactory(String brokerAddress) throws JMSException {
connectionFactory = new ConnectionFactory();
connectionFactory.setProperty(ConnectionConfiguration.imqAddressList, brokerAddress);
}
public Connection createConnection() throws JMSException {
return connectionFactory.createConnection();
}
public Connection createConnection(String userName, String password) throws JMSException {
return connectionFactory.createConnection(userName, password);
}
}
第二步:创建JMS接收类
package com.test.jms;
import org.springframework.core.task.TaskExecutor;
public class JMSReciever {
private TaskExecutor taskExecutor;
public JMSReciever(TaskExecutor taskExecutor){
this.taskExecutor = taskExecutor;
}
private class MessagePrinterTask implements Runnable{
private String message;
public MessagePrinterTask(String message){
this.message = message;
}
public void run() {
System.err.println(">>>>>>>>>>>>>>>>>>新线程中:"+message);
}
}
/**
* 接收消息
* @param msg:消息内容(spring监听到消息后执行此方法,并将消息内容付给msg参数中)
*/
public void receiveMSG(Object msg){
//这个方法可以写具体操作
System.err.println(">>>>>>>>>>>>>>>>>接收消息后:"+msg.toString());
taskExecutor.execute(new MessagePrinterTask("新线程参数"));
//此对象为消息中包含对象。例如:msg是map。Map msp = (Map)msg;
Object msgContent =msg;
}
}
第三步:编写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:jms="http://www.springframework.org/schema/jms"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-2.5.xsd"
default-lazy-init="true">
<jms:listener-container connection-factory="jmsFactory" task-executor="taskExecutor" concurrency="10" acknowledge="transacted">
<!--监听到序列号为MSG的消息时,通过会执行messageReceiver类中的receiveMSG方法
注意:MQtest与消息发送JMSUtil的参数queueName对应,即:接收指定队列中的消息。
-->
<jms:listener destination="MQtest" ref="messageReceiver" method="receiveMSG" /> <!--method监听到消息后要调用的方法-->
</jms:listener-container>
<!--mq连接工厂的实现。用于设置工厂构建连接地址-->
<bean id="jmsFactory" class="com.test.jms.OpenMqConnectionFactory">
<!--注入服务器地址-->
<constructor-arg type="java.lang.String" value="localhost:8080" />
</bean>
<!--监听到消息后要调用的类-->
<bean id="messageReceiver" class="com.test.jms.JMSReciever">
<constructor-arg ref="taskExecutor" />
</bean>
<!--spring的api,此类可以用execute(Runnable)来执行一个新线程。此类跟jms没关系只是自定义的类中注入一个”线程池任务执行者“,来执行其他自定义线程-->
<bean id="taskExecutor"
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="5" />
<property name="maxPoolSize" value="10" />
<property name="queueCapacity" value="5" />
</bean>
</beans>
依赖主要jar文件:
javaee.jar
imqjmsra.jar
分享到:
相关推荐
通过配置`ConnectionFactory`、`JmsTemplate`和消息监听器,我们可以方便地实现消息的发送和接收,从而提高系统的可扩展性和解耦性。同时,Spring提供的事务管理和异步处理功能进一步增强了JMS的实用性。在实际项目...
WebLogic Server是一款由Oracle公司提供的企业级应用服务器,它支持Java Message Service (JMS) 规范,允许在分布式环境中可靠地发送和接收消息。JMS是Java平台上的标准接口,用于实现应用程序间的异步通信。本文将...
在这个主题中,我们将深入探讨JMS消息的发送和订阅,以及如何通过Apache Camel这一集成框架来实现。 **JMS核心概念** 1. **消息**: JMS中的基本单元,它包含了要传递的数据。 2. **生产者**: 创建并发送消息的应用...
《Spring In Action 使用Spring发送和接收JMS消息》 在Java世界中,Spring框架以其强大的功能和灵活性,被广泛应用于企业级应用开发。本篇主要探讨如何利用Spring框架来发送和接收Java消息服务(Java Message ...
本文将详细解析如何通过编码实现MQ连接池,以便有效地管理和发送JMS消息。 首先,理解JMS的基本概念是至关重要的。JMS提供两种主要的消息模型:点对点(Point-to-Point,P2P)和发布/订阅(Publish/Subscribe,Pub/...
- 可以使用Spring的`JmsTemplate`进行发送消息的测试,或者通过WebLogic Server的管理控制台查看JMS资源的状态和消息队列。 通过以上知识,开发者可以构建一个基于Spring的Java应用,有效地利用WebLogic Server的...
-> 创建消息 -> 发送消息 -> 接收消息 -> 读取消息 为什么要使用消息 理由很简单,消息是一个分布式的低耦合通讯方案。A发送一个消息到一个agent ,B作为接受者去agent上获取消息。但是A,B不需要同时到agent上去...
Java消息服务(Java Message Service,简称JMS)是一个标准接口,它定义了应用程序如何创建、发送、接收和读取消息的标准API。JMS允许分布式系统中的不同组件通过消息进行通信,实现解耦和异步处理,提高系统的灵活...
5. 编写消息发送接口:为了将消息发送逻辑封装起来,可以创建一个服务类,提供发送消息的方法,这些方法可以根据需要接受不同的参数,比如消息主题和消息内容。 6. 发送消息业务类:在业务层,调用上述接口发送消息...
在IT行业中,Spring框架是Java应用开发中的一个关键组件,它提供了一整套服务和工具...对于新的项目,考虑使用更新的版本或其他的开源应用服务器(如Tomcat、WildFly)和消息中间件(如RabbitMQ、Kafka)可能更为合适。
在IT行业中,Java消息服务(Java Message Service,简称JMS)是一种标准,它定义了应用程序如何创建、发送、接收和读取消息的标准API。IBM MQ是IBM提供的一个强大的消息中间件,它允许分布式系统中的不同组件通过...
它定义了生产、发送、接收和读取消息的标准API,使得不同的消息中间件提供商可以提供兼容的实现,便于开发者在不同中间件之间进行迁移。JMS的核心概念包括消息、生产者、消费者、队列和主题。 1. **消息**:JMS中的...
同时,正确配置JMS连接工厂、目的地(如队列或主题)、以及消费者和生产者的实现是成功接收和发送消息的关键。记得在部署环境中添加这些依赖,并在代码中正确引用,以实现高效、可靠的JMS通信。
- JmsTransactionManager:用于声明和管理JMS消息发送和接收中的事务。 - UserCredentialsConnectionFactoryAdapter:用于封装一个已存在的连接工厂,并提供用户名和密码验证的支持。 - JmsOperations和JmsTemplate...
Java MQ通常指的是Java Message Service(JMS),这是一个Java平台上的API,用于在分布式环境中创建、发送、接收和读取消息。JMS允许应用程序创建和交换独立于提供商的消息,这意味着你可以更换消息队列服务而不必...
JMS(Java消息服务)是Java平台上的一个标准接口,它定义了生产、发送、接收和浏览消息的一组API。 创建一个Spring配置文件,你可以定义一个`ConnectionFactory`,它是与消息服务器建立连接的工厂类。接着,定义一...
3. **JMS消息结构**:JMS消息主要包括消息头、属性和消息体三个部分。 - **消息头**:包含消息的识别信息和路由信息。 - `JMSDestination`:消息发送的目的地。 - `JMSDeliveryMode`:指定消息是否需要持久化。 ...
Java 消息服务(JMS,Java Message Service)是一种用于在分布式系统中进行异步数据交换的API,它为应用程序提供了标准的接口来发送和接收消息。JMS规范由JavaSoft(现为Oracle公司的一部分)制定,目的是促进不同...