1. 依赖 jar
activemq-all-5.6.0.jar
jackson-all-1.8.5.jar
xstream-1.4.2.jar
2. Java 代码
/**
* 启动 JMS 服务
* @param args 参数
*/
public static void main(String[] args) throws Exception
{
BrokerService broker = new BrokerService();
broker.setBrokerId("broker1");
broker.setBrokerName("localhost1");
broker.addConnector("tcp://0.0.0.0:61616"); // 开启 tcp 协议
broker.addConnector("stomp://0.0.0.0:61613"); // 开启 stomp 协议
setJmsUserInfo(broker); // 设置用户信息
broker.start();
System.out.println("-- start JMS Server success. --");
}
/**
* 设置JMS用户信息
* @param broker broker
*/
private static void setJmsUserInfo(BrokerService broker)
{
AuthenticationUser user = new AuthenticationUser("user1", "password1", "group1");
List<AuthenticationUser> users = new ArrayList<AuthenticationUser>();
users.add(user);
SimpleAuthenticationPlugin auth = new SimpleAuthenticationPlugin();
auth.setUsers(users);
BrokerPlugin[] plugins = new BrokerPlugin[]{auth};
broker.setPlugins(plugins);
}
public class JMSInfo
{
// tcp 协议使用点对点模式时, 队列名称不需要前缀
public static final String QUEUE_NAME = "test_queue";
// tcp 协议使用发布/订阅模式时, 主题名称不需要前缀
public static final String TOPIC_NAME = "test_topic";
// stomp 协议使用点对点模式时, 需要有前缀 /queue/
public static final String STOMP_QUEUE_NAME = "/queue/" + QUEUE_NAME;
// stomp 协议使用发布/订阅模式时, 需要有前缀 /topic/
public static final String STOMP_TOPIC_NAME = "/topic/" + TOPIC_NAME;
}
分享到:
相关推荐
ApplicationContext ac = new ClassPathXmlApplicationContext("spring/applicationContext-jms-producer.xml"); //获取生产者发送消息服务接口 MessageSender messageSender = (MessageSender)ac.getBean...
NULL 博文链接:https://navylee.iteye.com/blog/987057
使用activeMQ来完成jms的发送,必须要下载activeMQ,然后再本机安装,并且启动activeMQ的服务才行。在官网下载完成之后,运行bin目录下面的activemq.bat,将activeMQ成功启动。启动成功之后可以运行:...
ActiveMQ、Apollo、Spring Jms 整合示例。 本实例演示环境为:ActiveMQ 5.10 、 Windows 7 X64 、jdk1.7、maven 3.0.5 本实例演示环境为:apollo-1.7 、 Windows 7 X64 、jdk1.7、maven 3.0.5 安装ActiveMQ 1. ...
带有ActiveMQ的Java消息服务 JMS或Java消息服务,通常用于发送消息或至少两个或更多应用程序的消息。 JMS与电子邮件不同。 系统要求 Java 玛文 Apache ActiveMQ入门 如何运行应用程序: 提炼 跑步 bin/activemq ...
jms 简单的案例,用的activemq,使用jms前请先启动activemq服务器
在Spring中安装ActiveMQ www.activemq.org apache-activemq-4.1.0-incubator.zip ,incubator.jar复制到lib中 启动ActiveMQ的脚本:运行刚下载的文件/bin/activemq.bat. 这样就可以使用ActiveMQ进行中介服务了。
master_slave文件夹允许您以主动-被动模式启动两个ActiveMQ代理。 代理的完整配置可以修改,因为它们是共享目录: conf /主 conf /从属 数据和日志位于conf / data目录中。 数据持久性可以通过KahaDB文件数据库来...
1启动ActiveMQ 运行C:\apache-activemq-5.2.0\bin\activemq.bat 2测试 ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动 netstat -an|find "61616" C:\Documents and ...
支持持久化的采用Spring整合activeMQ与quartz的JMS数据同步实例,包含依赖的jar包
在上面的日志信息中,我们可以看到 ActiveMQ 服务无法正常启动的错误信息是 “Failed to start ActiveMQ JMS Message Broker (localhost, null). Reason: java.io.IOException: Transport Connector could not be ...
这是一个简单的Spring JMS template例子,通过ActiveMQ中转消息,实现了发送和接收消息的基本功能 测试方法: 1:下载 ActiveMQ,并启动 2: 分别运行MessageReciver和MessageSender
apache-activemq-5.6.0 绿色版,解压即可启动
ActiveMQ - JMS 代理; Ehcache - Camel 缓存实现; Maven 的生命周期支持; 单元测试( jUnit启动嵌入式Jetty进行测试) 环境 应用程序是通过以下方式创建的: JDK 8u40 Tomcat 8.0.* 技术栈 阿帕奇骆驼 2.15...
简单的Java消息服务示例我发现JMS入门有点复杂。 甚至O'Reilly的“ Java Messaging Service”之类的好书也没有提供完整的项目示例。 在这里,我提供了第2章中的聊天示例,其中包含完整的构建系统和说明。建造生成...
先到官网下载activemq,启动后,就可以直接运行项目文件了
activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-
需要环境 1、activeMQ5.9.1下载启动后登陆,创建个quene名字为FirstQuene 2、下载gradle
一: ActiveMQ简介 包括:是什么、能干什么、特点;消息中间件的功能、特点、应用场景等 n 二: ActiveMQ安装和基本使用 包括:通过源码安装、基本的配置示例、启动、测试运行、关闭等 n 三:理解和掌握JMS 包括:...