- 浏览: 1074644 次
- 性别:
- 来自: 上海
-
文章分类
- 全部博客 (1441)
- 软件思想&演讲 (9)
- 行业常识 (250)
- 时时疑问 (5)
- java/guava/python/php/ruby/R/scala/groovy (213)
- struct/spring/springmvc (37)
- mybatis/hibernate/JPA (10)
- mysql/oracle/sqlserver/db2/mongdb/redis/neo4j/GreenPlum/Teradata/hsqldb/Derby/sakila (268)
- js/jquery/jqueryUi/jqueryEaseyUI/extjs/angulrJs/react/es6/grunt/zepto/raphael (81)
- ZMQ/RabbitMQ/ActiveMQ/JMS/kafka (17)
- lucene/solr/nuth/elasticsearch/MG4J (167)
- html/css/ionic/nodejs/bootstrap (19)
- Linux/shell/centos (56)
- cvs/svn/git/sourceTree/gradle/ant/maven/mantis/docker/Kubernetes (26)
- sonatype nexus (1)
- tomcat/jetty/netty/jboss (9)
- 工具 (17)
- ETL/SPASS/MATLAB/RapidMiner/weka/kettle/DataX/Kylin (11)
- hadoop/spark/Hbase/Hive/pig/Zookeeper/HAWQ/cloudera/Impala/Oozie (190)
- ios/swift/android (9)
- 机器学习&算法&大数据 (18)
- Mesos是Apache下的开源分布式资源管理框架 (1)
- echarts/d3/highCharts/tableau (1)
- 行业技能图谱 (1)
- 大数据可视化 (2)
- tornado/ansible/twisted (2)
- Nagios/Cacti/Zabbix (0)
- eclipse/intellijIDEA/webstorm (5)
- cvs/svn/git/sourceTree/gradle/jira/bitbucket (4)
- jsp/jsf/flex/ZKoss (0)
- 测试技术 (2)
- splunk/flunm (2)
- 高并发/大数据量 (1)
- freemarker/vector/thymeleaf (1)
- docker/Kubernetes (2)
- dubbo/ESB/dubboX/wso2 (2)
最新评论
1.下载ActiveMQ
去官方网站下载:http://activemq.apache.org/
2.运行ActiveMQ
将apache-activemq-5.5.1-bin.zip解压缩,双击apache-activemq-5.5.1\bin\activemq.bat运行ActiveMQ程序。
启动ActiveMQ以后,登陆:http://localhost:8161/admin/,创建一个Queue,命名为FirstQueue。
3.导入jar包:
4.实例
1、发送端
Java代码 收藏代码
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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 Sender {
/** 创建Session */
public static Session createSession() {
// 连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = null;
// MS 客户端到JMS Provider 的连接
Connection connection = null;
// 一个发送或接收消息的会话
Session session = null;
try {
// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
// 通过连接工厂创建连接
connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建Session
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
} catch (Exception e) {
e.printStackTrace();
}
return session;
}
/** 创建消息发送者 */
public static MessageProducer createProducer(Session session) {
// 消息的目的地;消息发送给谁.
Destination destination = null;
// 消息发送者
MessageProducer producer = null;
try {
// 获取session注意参数值FirstQueue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
// 消息--发送者
producer = session.createProducer(destination);
// 设置不持久化,实际根据项目决定
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
} catch (Exception e) {
e.printStackTrace();
}
return producer;
}
/** 发送消息 */
public static void sendMessage(Session session, MessageProducer producer,
String content) {
TextMessage textMessage = null;
try {
textMessage = session.createTextMessage(content);
producer.send(textMessage);
session.commit();// 提交
} catch (JMSException e) {
e.printStackTrace();
}
}
/** 测试 */
public static void main(String[] args) {
Session session = createSession();
MessageProducer producer = createProducer(session);
for (int i = 0; i < 5; i++) {
String content = "Message---" + i;
System.out.println(content);
sendMessage(session, producer, content);
}
}
}
2、接收端
Java代码 收藏代码
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class Receiver {
/** 创建Session */
public static Session createSession() {
// 连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = null;
// MS 客户端到JMS Provider 的连接
Connection connection = null;
// 一个发送或接收消息的会话
Session session = null;
try {
// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
// 通过连接工厂创建连接
connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建Session
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
} catch (Exception e) {
e.printStackTrace();
}
return session;
}
/** 创建消息接收者 */
public static MessageConsumer createConsumer(Session session) {
// 消息的目的地;消息发送给谁.
Destination destination = null;
// 消息接收者
MessageConsumer consumer = null;
try {
// 获取session注意参数值FirstQueue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
// 得到消息生成者"发送者"
consumer = session.createConsumer(destination);
} catch (Exception e) {
e.printStackTrace();
}
return consumer;
}
/** 发送消息 */
public static void receiverMessage(MessageConsumer consumer) {
try {
while (true) {
// 设置接收者接收消息的时间
TextMessage message = (TextMessage) consumer.receive(6 * 1000);
if (null != message) {
System.out.println("ReceiverMessage--" + message.getText());
} else {
System.out.println("break");
break;
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
/** 测试 */
public static void main(String[] args) {
receiverMessage(createConsumer(createSession()));
}
}
5、测试结果
执行Sender:
Message---0
Message---1
Message---2
Message---3
Message---4
执行Receive:
ReceiverMessage--Message---0
ReceiverMessage--Message---1
ReceiverMessage--Message---2
ReceiverMessage--Message---3
ReceiverMessage--Message---4
去官方网站下载:http://activemq.apache.org/
2.运行ActiveMQ
将apache-activemq-5.5.1-bin.zip解压缩,双击apache-activemq-5.5.1\bin\activemq.bat运行ActiveMQ程序。
启动ActiveMQ以后,登陆:http://localhost:8161/admin/,创建一个Queue,命名为FirstQueue。
3.导入jar包:
4.实例
1、发送端
Java代码 收藏代码
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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 Sender {
/** 创建Session */
public static Session createSession() {
// 连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = null;
// MS 客户端到JMS Provider 的连接
Connection connection = null;
// 一个发送或接收消息的会话
Session session = null;
try {
// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
// 通过连接工厂创建连接
connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建Session
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
} catch (Exception e) {
e.printStackTrace();
}
return session;
}
/** 创建消息发送者 */
public static MessageProducer createProducer(Session session) {
// 消息的目的地;消息发送给谁.
Destination destination = null;
// 消息发送者
MessageProducer producer = null;
try {
// 获取session注意参数值FirstQueue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
// 消息--发送者
producer = session.createProducer(destination);
// 设置不持久化,实际根据项目决定
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
} catch (Exception e) {
e.printStackTrace();
}
return producer;
}
/** 发送消息 */
public static void sendMessage(Session session, MessageProducer producer,
String content) {
TextMessage textMessage = null;
try {
textMessage = session.createTextMessage(content);
producer.send(textMessage);
session.commit();// 提交
} catch (JMSException e) {
e.printStackTrace();
}
}
/** 测试 */
public static void main(String[] args) {
Session session = createSession();
MessageProducer producer = createProducer(session);
for (int i = 0; i < 5; i++) {
String content = "Message---" + i;
System.out.println(content);
sendMessage(session, producer, content);
}
}
}
2、接收端
Java代码 收藏代码
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class Receiver {
/** 创建Session */
public static Session createSession() {
// 连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = null;
// MS 客户端到JMS Provider 的连接
Connection connection = null;
// 一个发送或接收消息的会话
Session session = null;
try {
// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
// 通过连接工厂创建连接
connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建Session
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
} catch (Exception e) {
e.printStackTrace();
}
return session;
}
/** 创建消息接收者 */
public static MessageConsumer createConsumer(Session session) {
// 消息的目的地;消息发送给谁.
Destination destination = null;
// 消息接收者
MessageConsumer consumer = null;
try {
// 获取session注意参数值FirstQueue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
// 得到消息生成者"发送者"
consumer = session.createConsumer(destination);
} catch (Exception e) {
e.printStackTrace();
}
return consumer;
}
/** 发送消息 */
public static void receiverMessage(MessageConsumer consumer) {
try {
while (true) {
// 设置接收者接收消息的时间
TextMessage message = (TextMessage) consumer.receive(6 * 1000);
if (null != message) {
System.out.println("ReceiverMessage--" + message.getText());
} else {
System.out.println("break");
break;
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
/** 测试 */
public static void main(String[] args) {
receiverMessage(createConsumer(createSession()));
}
}
5、测试结果
执行Sender:
Message---0
Message---1
Message---2
Message---3
Message---4
执行Receive:
ReceiverMessage--Message---0
ReceiverMessage--Message---1
ReceiverMessage--Message---2
ReceiverMessage--Message---3
ReceiverMessage--Message---4
发表评论
-
ActiveMQ安装与使用
2017-12-11 18:07 816一 .安装运行ActiveMQ: ... -
MQ的使用
2017-12-11 18:18 443安装环境:linux redhat activemq版本 ... -
mq常用命令
2017-12-11 18:20 520创建队列管理器 crtmqm qmgrname 删 ... -
Activemq的端口监听介绍及端口优化
2018-01-07 09:06 620在activemq的conf/activemq.x ... -
ActiveMq启动停止
2017-10-25 10:05 1286Linux操作系统 进入bin目录下,64位操作系统可以进 ... -
RabbitMq、ActiveMq、ZeroMq、kafka之间的比较,资料汇总
2017-07-21 14:21 1013MQ框架非常之多,比较流行的有RabbitMq、Active ... -
使用activemq
2017-06-29 14:32 486说说在项目里是怎么使用activemq(简称为amq)进行通 ... -
activeMQ启动失败61616端口被占用问题
2017-03-27 23:19 1809通过netstat -aon | findstr " ... -
Kafka 对比 ActiveMQ
2016-12-13 13:00 1787Kafka 是LinkedIn 开发的一个高性能、分布式的 ... -
ActiveMQ的工作原理
2016-11-14 10:19 739如图所示 首先来看本地通讯的情况,应用程序A和应用程 ... -
Spring整合JMS----基于ActiveMQ的实现
2016-12-27 10:22 4271.1 JMS简介 JMS的全称是Ja ... -
Spring整合JMS的三种监听
2016-12-30 11:47 863在Spring整合JMS的应用中我们在定义消息监听器的时候一共 ... -
Spring整合JMS的MessageConverter
2016-12-30 11:43 471消息转换器MessageConverter Me ... -
Spring整合JMS
2016-12-30 11:44 439Spring提供了一个JmsTransac ... -
zmq的介绍
2015-12-11 11:52 716http://blog.csdn.net/lfsf802/ar ... -
kafka特点
2015-11-23 02:07 1144一、入门 1、简介 Kafka is a di ...
相关推荐
内容概要:本文详细介绍了基于MATLAB GUI界面和卷积神经网络(CNN)的模糊车牌识别系统。该系统旨在解决现实中车牌因模糊不清导致识别困难的问题。文中阐述了整个流程的关键步骤,包括图像的模糊还原、灰度化、阈值化、边缘检测、孔洞填充、形态学操作、滤波操作、车牌定位、字符分割以及最终的字符识别。通过使用维纳滤波或最小二乘法约束滤波进行模糊还原,再利用CNN的强大特征提取能力完成字符分类。此外,还特别强调了MATLAB GUI界面的设计,使得用户能直观便捷地操作整个系统。 适合人群:对图像处理和深度学习感兴趣的科研人员、高校学生及从事相关领域的工程师。 使用场景及目标:适用于交通管理、智能停车场等领域,用于提升车牌识别的准确性和效率,特别是在面对模糊车牌时的表现。 其他说明:文中提供了部分关键代码片段作为参考,并对实验结果进行了详细的分析,展示了系统在不同环境下的表现情况及其潜在的应用前景。
嵌入式八股文面试题库资料知识宝典-计算机专业试题.zip
嵌入式八股文面试题库资料知识宝典-C and C++ normal interview_3.zip
内容概要:本文深入探讨了一款额定功率为4kW的开关磁阻电机,详细介绍了其性能参数如额定功率、转速、效率、输出转矩和脉动率等。同时,文章还展示了利用RMxprt、Maxwell 2D和3D模型对该电机进行仿真的方法和技术,通过外电路分析进一步研究其电气性能和动态响应特性。最后,文章提供了基于RMxprt模型的MATLAB仿真代码示例,帮助读者理解电机的工作原理及其性能特点。 适合人群:从事电机设计、工业自动化领域的工程师和技术人员,尤其是对开关磁阻电机感兴趣的科研工作者。 使用场景及目标:适用于希望深入了解开关磁阻电机特性和建模技术的研究人员,在新产品开发或现有产品改进时作为参考资料。 其他说明:文中提供的代码示例仅用于演示目的,实际操作时需根据所用软件的具体情况进行适当修改。
少儿编程scratch项目源代码文件案例素材-剑客冲刺.zip
少儿编程scratch项目源代码文件案例素材-几何冲刺 转瞬即逝.zip
内容概要:本文详细介绍了基于PID控制器的四象限直流电机速度驱动控制系统仿真模型及其永磁直流电机(PMDC)转速控制模型。首先阐述了PID控制器的工作原理,即通过对系统误差的比例、积分和微分运算来调整电机的驱动信号,从而实现转速的精确控制。接着讨论了如何利用PID控制器使有刷PMDC电机在四个象限中精确跟踪参考速度,并展示了仿真模型在应对快速负载扰动时的有效性和稳定性。最后,提供了Simulink仿真模型和详细的Word模型说明文档,帮助读者理解和调整PID控制器参数,以达到最佳控制效果。 适合人群:从事电力电子与电机控制领域的研究人员和技术人员,尤其是对四象限直流电机速度驱动控制系统感兴趣的读者。 使用场景及目标:适用于需要深入了解和掌握四象限直流电机速度驱动控制系统设计与实现的研究人员和技术人员。目标是在实际项目中能够运用PID控制器实现电机转速的精确控制,并提高系统的稳定性和抗干扰能力。 其他说明:文中引用了多篇相关领域的权威文献,确保了理论依据的可靠性和实用性。此外,提供的Simulink模型和Word文档有助于读者更好地理解和实践所介绍的内容。
嵌入式八股文面试题库资料知识宝典-2013年海康威视校园招聘嵌入式开发笔试题.zip
少儿编程scratch项目源代码文件案例素材-驾驶通关.zip
小区开放对周边道路通行能力影响的研究.pdf
内容概要:本文探讨了冷链物流车辆路径优化问题,特别是如何通过NSGA-2遗传算法和软硬时间窗策略来实现高效、环保和高客户满意度的路径规划。文中介绍了冷链物流的特点及其重要性,提出了软时间窗概念,允许一定的配送时间弹性,同时考虑碳排放成本,以达到绿色物流的目的。此外,还讨论了如何将客户满意度作为路径优化的重要评价标准之一。最后,通过一段简化的Python代码展示了遗传算法的应用。 适合人群:从事物流管理、冷链物流运营的专业人士,以及对遗传算法和路径优化感兴趣的科研人员和技术开发者。 使用场景及目标:适用于冷链物流企业,旨在优化配送路线,降低运营成本,减少碳排放,提升客户满意度。目标是帮助企业实现绿色、高效的物流配送系统。 其他说明:文中提供的代码仅为示意,实际应用需根据具体情况调整参数设置和模型构建。
少儿编程scratch项目源代码文件案例素材-恐怖矿井.zip
内容概要:本文详细介绍了基于STM32F030的无刷电机控制方案,重点在于高压FOC(磁场定向控制)技术和滑膜无感FOC的应用。该方案实现了过载、过欠压、堵转等多种保护机制,并提供了完整的源码、原理图和PCB设计。文中展示了关键代码片段,如滑膜观测器和电流环处理,以及保护机制的具体实现方法。此外,还提到了方案的移植要点和实际测试效果,确保系统的稳定性和高效性。 适合人群:嵌入式系统开发者、电机控制系统工程师、硬件工程师。 使用场景及目标:适用于需要高性能无刷电机控制的应用场景,如工业自动化设备、无人机、电动工具等。目标是提供一种成熟的、经过验证的无刷电机控制方案,帮助开发者快速实现并优化电机控制性能。 其他说明:提供的资料包括详细的原理图、PCB设计文件、源码及测试视频,方便开发者进行学习和应用。
基于有限体积法Godunov格式的管道泄漏检测模型研究.pdf
嵌入式八股文面试题库资料知识宝典-CC++笔试题-深圳有为(2019.2.28)1.zip
少儿编程scratch项目源代码文件案例素材-几何冲刺 V1.5.zip
Android系统开发_Linux内核配置_USB-HID设备模拟_通过root权限将Android设备转换为全功能USB键盘的项目实现_该项目需要内核支持configFS文件系统
C# WPF - LiveCharts Project
少儿编程scratch项目源代码文件案例素材-恐怖叉子 动画.zip
嵌入式八股文面试题库资料知识宝典-嵌⼊式⼯程师⾯试⾼频问题.zip