lib:
jms1.1.jar
activemq-all-5.0.jar
首先启动 activemq.bat或者执行以下代码启动一个broker
import org.apache.activemq.broker.BrokerService;
/**
* This example demonstrates how to run an embedded broker inside your Java code
*
* @version $Revision: 565003 $
*/
public final class EmbeddedBroker {
private EmbeddedBroker() {
}
public static void main(String[] args) throws Exception {
BrokerService broker = new BrokerService();
broker.setUseJmx(true);
broker.addConnector("tcp://localhost:61616");
broker.start();
// now lets wait forever to avoid the JVM terminating immediately
Object lock = new Object();
synchronized (lock) {
lock.wait();
}
}
}
消费端
package com.jms;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class ConsumerTool implements MessageListener {
private String user = ActiveMQConnection.DEFAULT_USER;
private String password = ActiveMQConnection.DEFAULT_PASSWORD;
private String url = ActiveMQConnection.DEFAULT_BROKER_URL;
private String subject = "TOOL.DEFAULT";
private Destination destination = null;
private Connection connection = null;
private Session session = null;
private MessageConsumer consumer = null;
//初始化
private void initialize() throws JMSException, Exception{
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, url);
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue(subject);
consumer = session.createConsumer(destination);
}
//消费消息
public void consumeMessage() throws JMSException, Exception{
initialize();
connection.start();
System.out.println("Consumer:->Begin listening...");
//开始监听
consumer.setMessageListener(this);
//Message message = consumer.receive();
}
//关闭连接
public void close() throws JMSException{
System.out.println("Consumer:->Closing connection");
if (consumer != null) consumer.close();
if (session != null) session.close();
if (connection != null) connection.close();
}
public void onMessage(Message message) {
try{
if (message instanceof TextMessage){
TextMessage txtMsg = (TextMessage) message;
String msg = txtMsg.getText();
System.out.println("Consumer:->Received: " + msg);
} else{
System.out.println("Consumer:->Received: " + message);
}
} catch (JMSException e){
e.printStackTrace();
}
}
}
producter:
package com.jms;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class ProducerTool {
private String user = ActiveMQConnection.DEFAULT_USER;
private String password = ActiveMQConnection.DEFAULT_PASSWORD;
private String url = ActiveMQConnection.DEFAULT_BROKER_URL;
private String subject = "TOOL.DEFAULT";
private Destination destination = null;
private Connection connection = null;
private Session session = null;
private MessageProducer producer = null;
//初始化
private void initialize() throws JMSException, Exception{
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, url);
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue(subject);
producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
//发送消息
public void produceMessage(String message) throws JMSException, Exception{
initialize();
TextMessage msg = session.createTextMessage(message);
connection.start();
System.out.println("Producer:->Sending message: " + message);
producer.send(msg);
System.out.println("Producer:->Message sent complete!");
}
//关闭连接
public void close() throws JMSException{
System.out.println("Producer:->Closing connection");
if (producer != null) producer.close();
if (session != null) session.close();
if (connection != null) connection.close();
}
}
下面是一个Broker实现,不属于同一个例子!
package com.jms;
import java.io.IOException;
import java.util.Hashtable;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class MessageBroker extends HttpServlet
{
private ConnectionFactory confactory=null;
private Connection jmsCon=null;
private Destination dest=null;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException
{
this.doPost(req, resp);
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException
{
Session session;
try
{
String deptId=null;
String deptName=null;
deptId=req.getParameter("deptId");
deptName=req.getParameter("deptName");
session = this.jmsCon.createSession(false, Session.CLIENT_ACKNOWLEDGE);
MessageProducer msgProducer=session.createProducer(dest);
Message textMsg=session.createTextMessage();
textMsg.setStringProperty("deptId", deptId);
textMsg.setStringProperty("deptName", deptName);
msgProducer.send(textMsg);
session.close();
resp.sendRedirect("http://localhost/JmsTestWeb2/");
}
catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
*
*/
public void init(ServletConfig config) throws ServletException
{
super.init(config);
try
{
this.confactory=this.getConnectionFactoryFromLdap();
this.dest=this.getDestinationFromLdap();
this.jmsCon=this.confactory.createConnection();
/** 开启一个会话来创建一个消息消费者,异步监听到来的消息。*/
Session session=jmsCon.createSession(false, Session.CLIENT_ACKNOWLEDGE);
MessageConsumer msgConsumer=session.createConsumer(this.dest);
MessageListenerForOrgMsg msgListener=new MessageListenerForOrgMsg();
msgConsumer.setMessageListener(msgListener);
/** 开启另一个会话来创建另外一个消息消费者,异步监听到来的消息。*/
Session session2=jmsCon.createSession(false, Session.CLIENT_ACKNOWLEDGE);
MessageConsumer msgConsumer2=session2.createConsumer(this.dest);
MessageListenerForOrgMsg2 msgListener2=new MessageListenerForOrgMsg2();
msgConsumer2.setMessageListener(msgListener2);
this.jmsCon.start();
}
catch (Exception e)
{
e.printStackTrace();
}
}
/**
*
* @return
* @throws NamingException
*/
private ConnectionFactory getConnectionFactoryFromLdap() throws NamingException
{
String account="uid=admin,ou=administrators,ou=topologymanagement,o=netscaperoot";//操作LDAP的帐户。默认就是Admin。
String password="111111" ;//帐户Admin的密码。
String root="ou=jmsstore,dc=xindongfang,dc=com"; //所操作的WLS域。也就是LDAP的根节点的DC
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");//必须这样写,无论用什么LDAP服务器。
env.put(Context.PROVIDER_URL, "ldap://192.168.0.15:2922/" + root);//LDAP服务器的地址:端口。对WLS端口就是7001
env.put(Context.SECURITY_AUTHENTICATION, "simple");//授权界别,可以有三种授权级别,但是如果设为另外两种都无法登录,我也不知道为啥,但是只能设成这个值"none"。
env.put(Context.SECURITY_PRINCIPAL, account );//载入登陆帐户和登录密码
env.put(Context.SECURITY_CREDENTIALS, password);
InitialContext ctx=null;
ConnectionFactory conFacotry=null;
try
{
ctx = new InitialContext(env);//初始化上下文
conFacotry=(ConnectionFactory)ctx.lookup("cn=topicconfac");
System.out.println("get Connection factory success");
return conFacotry;
}
finally
{
if (ctx!=null) ctx.close();
}
}
/**
*
* @return
* @throws NamingException
*/
private Destination getDestinationFromLdap() throws NamingException
{
String account="uid=admin,ou=administrators,ou=topologymanagement,o=netscaperoot";//操作LDAP的帐户。默认就是Admin。
String password="111111" ;//帐户Admin的密码。
String root="ou=jmsstore,dc=xindongfang,dc=com"; //所操作的WLS域。也就是LDAP的根节点的DC
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");//必须这样写,无论用什么LDAP服务器。
env.put(Context.PROVIDER_URL, "ldap://192.168.0.15:2922/" + root);//LDAP服务器的地址:端口。对WLS端口就是7001
env.put(Context.SECURITY_AUTHENTICATION, "simple");//授权类别,可以有三种授权级别,但是如果设为另外两种都无法登录,我也不知道为啥,但是只能设成这个值"none"。
env.put(Context.SECURITY_PRINCIPAL, account );//载入登陆帐户和登录密码
env.put(Context.SECURITY_CREDENTIALS, password);
InitialContext ctx=null;
Destination dst=null;
try
{
ctx = new InitialContext(env);//初始化上下文
dst=(Destination)ctx.lookup("cn=orgmsg");
System.out.println("get destination success");
return dst;
}
finally
{
if (ctx!=null) ctx.close();
}
}
public void destroy()
{
if (this.jmsCon!=null)
{
try
{
this.jmsCon.close();
}
catch (JMSException e)
{
e.printStackTrace();
}
}
super.destroy();
}
}
分享到:
相关推荐
Classes contained in javax.jms.jar: javax.transaction.xa.XAResource.class javax.jms.BytesMessage.class javax.jms.Message.class javax.jms.JMSException.class javax.jms.Destination.class javax.jms....
javax.jms.BytesMessage.class javax.jms.Connection.class javax.jms.ConnectionConsumer.class javax.jms.ConnectionFactory.class javax.jms.ConnectionMetaData.class javax.jms.DeliveryMode.class javax.jms....
**JMS583芯片详解** JMS583是一款由JMicron科技公司设计的高性能USB 3.1 Gen 2至PCIe Gen3x2桥接芯片,旨在为存储设备提供高速数据传输能力。这款芯片是针对现代数据密集型应用而优化的,如SSD固态硬盘和外部存储...
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用间异步通信的标准接口。它提供了一种可靠的消息传递机制,允许应用程序创建、发送、接收和读取消息。`jms-1.1.jar` 是一个包含了JMS 1.1...
`javax.jms.jar` 文件中包含了如`javax.jms.Queue`, `javax.jms.Topic`, `javax.jms.MessageProducer`, `javax.jms.MessageConsumer`, `javax.jms.ConnectionFactory`等关键接口,以及其他辅助类和异常类,开发者...
文件包含: 13个不同固件 两个固件升级工具 其中一个是量产工具可以修改休眠时间和盒子信息 TRIM检查工具 有几个固件版本为全网首发,别人没有的资源 固件列表: JMS578_00.01.00.05 ...JMS578_254.02.03.09_NoUAS
JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS(JMS
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的API,它定义了一组标准接口,允许应用程序创建、发送、接收和读取消息。`javax.jms`包是JMS规范的核心部分,包含了各种与消息传递...
`javax.jms-1.1.jar` 是一个Java Message Service(JMS)的API库,它属于Java标准版(Java Standard Edition, Java SE)的一部分。JMS是Java平台上的一个规范,用于在分布式环境中进行异步消息传递。这个库主要用于...
Java Messaging Service(JMS)是一种标准的API,用于在Java应用程序之间交换消息,特别是在分布式环境中。JMS提供了一种与平台无关的方式,使得应用程序可以与各种消息中间件提供商进行交互,就像JDBC允许Java应用...
JMicron JMS578 USB/SATA bridge JMS578介绍手册JMS578_Product+Brief.pdf JMS578固件(支持Android系统/linux系统) JMS578 windows的烧录工具和JMS578FwUpdate JMS578-Hardkenel-Release-v173.01.00.02-20190306....
Java 消息服务(JMS,Java Message Service)是一种用于在分布式系统中进行异步数据交换的API,它为应用程序提供了标准的接口来发送和接收消息。JMS规范由JavaSoft(现为Oracle公司的一部分)制定,目的是促进不同...
《JMS 1.1.jar:Java消息服务与Maven的深度解析》 在Java开发领域,消息服务(Java Message Service,简称JMS)扮演着至关重要的角色,它为应用程序提供了一种标准的方式来创建、发送、接收和读取消息。JMS 1.1.jar...
**JMS583 USB转PCIE桥接芯片方案** JMS583是一款由JMicron科技公司设计的高效能USB到PCI Express (PCIe)桥接芯片,旨在为电子设备提供一种灵活的方式来实现高速数据传输。这款芯片能够将USB接口转换成PCIe接口,以...
标题“JMS577主控通刷固件”指的是针对希捷移动硬盘中采用JMS577主控芯片的固件更新解决方案。在IT领域,固件是存储在硬件设备上的软件部分,它控制设备的操作并提供与主机系统的交互。JMS577是一种常见的硬盘主控...
OSB 中 JMS 配置及队列使用说明 OSB(Oracle Service Bus)是一种基于 Java 的集成平台,旨在帮助企业集成不同的应用程序和系统。JMS(Java Message Service)是 Java 平台上的一种消息服务规范,允许 Java 应用...
标题中的“USB转SATA硬盘盒JMS583量产工具”是指一种专门用于将USB接口转换为SATA接口的硬件设备,其中JMS583是该转换器的主控芯片。这种硬盘盒允许用户将传统的SATA硬盘通过USB接口连接到电脑上,方便数据迁移、...
WebLogic Server是一款由Oracle公司提供的企业级应用服务器,它支持Java Message Service (JMS) 规范,允许在分布式环境中可靠地发送和接收消息。JMS是Java平台上的标准接口,用于实现应用程序间的异步通信。本文将...
Weblogic JMS 依赖jar包是Oracle公司的中间件产品Weblogic Server中用于实现Java Message Service (JMS) 功能的关键组件。JMS是一种标准API,它允许应用程序在分布式环境中发送和接收消息,提供了异步通信的能力。在...