ActiveMQ queue 代码示例

生产者：

package com.111.activemq;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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 JMSProducer {//默认连接用户名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接密码private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//发送的消息数量private static final int SENDNUM = 10;public static void main(String[] args) {//连接工厂
        ConnectionFactory connectionFactory;//连接Connection connection = null;//会话 接受或者发送消息的线程Session session = null;//消息的目的地
        Destination destination;//消息生产者
        MessageProducer messageProducer;//消息队列名称String queueName = "helloWord"; //实例化连接工厂connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKEURL);try {//通过连接工厂获取连接connection = connectionFactory.createConnection();//启动连接
            connection.start();//创建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//创建一个连接自定义队列名称的消息队列destination = session.createQueue(queueName);//创建消息生产者messageProducer = session.createProducer(destination);//发送消息
            sendMessage(session, messageProducer);session.commit();} catch (Exception e) {e.printStackTrace();}finally{if(connection != null){try {session.close();connection.close();} catch (JMSException e) {e.printStackTrace();}}}}/*** 发送消息* @param session* @param messageProducer  消息生产者* @throws Exception*/public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i = 0; i < SENDNUM; i++) {//创建一条文本消息 TextMessage message = session.createTextMessage("ActiveMQ 发送消息" +i);System.out.println("发送消息：Activemq 发送消息" + i);//通过消息生产者发出消息 
            messageProducer.send(message);}}
}

消费者：

package com.111.activemq;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class JMSConsumer {//默认连接用户名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接密码private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;public static void main(String[] args) {//连接工厂
        ConnectionFactory connectionFactory;//连接Connection connection = null;//会话 接受或者发送消息的线程
        Session session;//消息的目的地
        Destination destination;//消息的消费者
        MessageConsumer messageConsumer;//消息队列名称String queueName = "helloWord";//实例化连接工厂connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKEURL);try {//通过连接工厂获取连接connection = connectionFactory.createConnection();//启动连接
            connection.start();//创建sessionsession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//创建一个连接自定义队列名称的消息队列destination = session.createQueue(queueName);//创建消息消费者messageConsumer = session.createConsumer(destination);while (true) {TextMessage textMessage = (TextMessage) messageConsumer.receive(100000);if(textMessage != null){System.out.println("收到的消息:" + textMessage.getText());}else {break;}}} catch (JMSException e) {e.printStackTrace();}}
}

多线程生产者：

package com.111.activemq;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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 JMSProducerMultithreading implements Runnable{//默认连接用户名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接密码private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//发送的消息数量private static final int SENDNUM = 3;/*** 发送消息* @param session* @param messageProducer  消息生产者* @throws Exception*/public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i = 0; i < SENDNUM; i++) {//获取当前线程idString threadId = Thread.currentThread().getId()+"";//创建一条文本消息 TextMessage message = session.createTextMessage("ActiveMQ 发送消息" +i+"生产者线程编号="+threadId);//控制台打印System.out.println("ActiveMQ 发送消息" +i+"生产者线程编号="+threadId);//通过消息生产者发出消息 
            messageProducer.send(message);}}@Overridepublic void run() {//连接工厂
        ConnectionFactory connectionFactory;//连接Connection connection = null;//会话 接受或者发送消息的线程Session session = null;//消息的目的地
        Destination destination;//消息生产者
        MessageProducer messageProducer;//消息队列名称String queueName = "Multithreading";//实例化连接工厂connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKEURL);try {//通过连接工厂获取连接connection = connectionFactory.createConnection();//启动连接
            connection.start();//创建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//创建一个名称为HelloWorld的消息队列destination = session.createQueue(queueName);//创建消息生产者messageProducer = session.createProducer(destination);//发送消息
            sendMessage(session, messageProducer);session.commit();} catch (Exception e) {e.printStackTrace();}finally{if(connection != null){try {session.close();connection.close();} catch (JMSException e) {e.printStackTrace();}}}}
}

多线程消费者：

package com.111.activemq;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;public class JMSConsumerMultithreading implements Runnable{//默认连接用户名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接密码private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;@Overridepublic void run() {ConnectionFactory connectionFactory;//连接工厂Connection connection = null;//连接
Session session;//会话 接受或者发送消息的线程Destination destination;//消息的目的地
MessageConsumer messageConsumer;//消息的消费者//消息队列名称String queueName = "Multithreading";//实例化连接工厂connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKEURL);try {//通过连接工厂获取连接connection = connectionFactory.createConnection();//启动连接
            connection.start();//创建sessionsession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//创建一个连接HelloWorld的消息队列destination = session.createQueue(queueName);//创建消息消费者messageConsumer = session.createConsumer(destination);String threadId = Thread.currentThread().getId()+""; while (true) {TextMessage textMessage = (TextMessage) messageConsumer.receive(100000);if(textMessage != null){System.out.println("收到的消息:" + textMessage.getText()+" 消费者线程编号="+threadId);}else {break;}}} catch (JMSException e) {e.printStackTrace();}}
}

多线程生产者测试类：

package com.111.activemq;public class JMSProducerMultithreadingTest {public static void main(String[] args) {JMSProducerMultithreading jpm = new JMSProducerMultithreading();//启动10个生产者线程for(int i = 0 ; i < 10 ; i++){Thread t = new Thread(jpm);t.start();}}
}

多线程消费者测试类：

package com.111.activemq;public class JMSConsumerMultithreadingTest {public static void main(String[] args) {JMSConsumerMultithreading jcm = new JMSConsumerMultithreading();//启动3个消费者者线程for(int i = 0 ; i < 3 ; i++){Thread t = new Thread(jcm);t.start();}}
}

 

转载于:https://www.cnblogs.com/MIC2016/p/6098647.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/402615.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

SpringBoot时间戳与MySql数据库记录相差14小时排错

SpringBoot时间戳与MySql数据库记录相差14小时排错

From: http://www.cnblogs.com/jason1990/archive/2018/11/28/10032181.html 项目中遇到存储的时间戳与真实时间相差14小时的现象,以下为解决步骤. 问题 CREATE TABLE incident (id int(11) NOT NULL AUTO_INCREMENT,created_time timestamp NOT NULL DEFAULT CURRENT_TIMES…
阅读更多...
HDU 1233 还是畅通工程（最小生成树）

HDU 1233 还是畅通工程（最小生成树）

传送门 还是畅通工程 Time Limit: 4000/2000 MS (Java/Others) Memory Limit: 65536/32768 K (Java/Others)Total Submission(s): 41447 Accepted Submission(s): 18920 Description 某省调查乡村交通状况&#xff0c;得到的统计表中列出了任意两村庄间的距离。省政府“畅…
阅读更多...
出了本练内功的书：《完美软件开发：方法与逻辑》

出了本练内功的书：《完美软件开发：方法与逻辑》

首先说下什么叫“完美软件开发”&#xff0c;想象一下&#xff0c;完美的圆在现实中是不存在的&#xff0c;现实中的圆只能是对完美的圆的回归&#xff0c;但完美的圆描述了圆的构成规则&#xff0c;完美软件开发意义与此相同&#xff0c;它试图描述软件开发的规则和铁律。但既…
阅读更多...
Springboot后台接收前端Date类型

Springboot后台接收前端Date类型

From: https://my.oschina.net/zicheng/blog/2963117 这个问题不是专门针对Springboot的&#xff0c;Springmvc也同样适用于这一个问题。 昨的是Springboot前后端分离的项目&#xff0c;今天和前端对接口发现前端的请求走不到后台&#xff0c;检查了请求什么的都没有问题&…
阅读更多...
关于jTopo的引用

关于jTopo的引用

jTopo是一款 2 D和3D模型展示的插件&#xff0c;不过目前文档不是很齐全&#xff0c;刚开始看的时候就有点懵了&#xff0c;因为你在网上很难找到jTopo的资料。下面我就介绍一下jTopo 的引用吧。 1、首先在官网上下载到jTopo的包&#xff0c;地址&#xff1a;http://www.jtopo.…
阅读更多...
mysql重置root密码方法

mysql重置root密码方法

2019独角兽企业重金招聘Python工程师标准>>> 1. 先关闭mysqld 2. 运行&#xff1a; mysqld_safe --skip-grant-tables 3. 另开一个窗口&#xff0c;用 mysql -uroot 登录mysql&#xff0c;执行 UPDATE mysql.user SET PasswordPASSWORD(你的密码) WHERE User…
阅读更多...
插入排序之C++实现

插入排序之C++实现

描述 插入排序是一种简单直观的排序算法。它的基本思想是将一个待排序的数据序列分为已排序和未排序两部分&#xff0c;每次从未排序序列中取出一个元素&#xff0c;然后将它插入到已排序序列的适当位置&#xff0c;直到所有元素都插入完毕&#xff0c;即完成排序。 实现思路…
阅读更多...
spring boot使用logback实现多环境日志配置

spring boot使用logback实现多环境日志配置

From: https://blog.csdn.net/vitech/article/details/53812137 软件生存周期中&#xff0c;涉及代码运行的环节有编码、测试和维护阶段&#xff0c;而一套成熟的代码&#xff0c;在此三个阶段&#xff0c;数据库、日志路径、日志级别、线程池大小等配置一般会不一样。作为开发…
阅读更多...
IOT(Index Organized Table)

IOT(Index Organized Table)

我们知道一般的表都以堆(heap)的形式来组织的&#xff0c;这是无序的组织方式。Oracle还提供了一种有序的表&#xff0c;它就是索引组织表&#xff0c;简称IOT表。IOT表上必须要有主键&#xff0c;而IOT表本身不对应segment&#xff0c;表里所有的数据都存放在主键所在的索引的…
阅读更多...
C++中的 :: 用法

C++中的 :: 用法

::是运算符中等级最高的&#xff0c;它分为三种:1)global scope(全局作用域符&#xff09;&#xff0c;用法&#xff08;::name)2)class scope(类作用域符&#xff09;&#xff0c;用法(class::name)3)namespace scope(命名空间作用域符&#xff09;&#xff0c;用法(namespace…
阅读更多...
Spring Boot SLF4J日志实例

Spring Boot SLF4J日志实例

From: https://blog.csdn.net/lxh18682851338/article/details/78560295 默认情况下&#xff0c;SLF4j日志记录包含在Spring Boot Web应用程序中&#xff0c;只需要启用它就可以了。 注意&#xff1a;查看此Spring Boot Logback XML模板以了解默认的日志记录模式和配置。 SLF4…
阅读更多...
java 反取字符串

java 反取字符串

public class demo2 {/*** 2 : 将字符串反取出来 新中国好 好国中新*/public static void main(String[] args) {String s "新中国好";s reverse1(s);System.out.println("方法一&#xff1a;" s);s reverse2(s);System.out.println("方法二…
阅读更多...
测试使用wiz来发布blog

测试使用wiz来发布blog

晚上尝试了下用wiz写随笔并发布&#xff0c;貌似成功了&#xff0c;虽然操作体验和方便性上不如word&#xff0c;但起码它集成了这个简单的功能可以让我用&#xff1a;如果能让我自动新建blog文章并自动定时更新发布就完美了。2013年7月5日19:31:04发现最近开始慢慢重度使用wiz…
阅读更多...
Spring在Java Filter注入Bean为Null的问题解决

Spring在Java Filter注入Bean为Null的问题解决

From: https://www.cnblogs.com/EasonJim/p/7666009.html 在Spring的自动注入中普通的POJO类都可以使用Autowired进行自动注入&#xff0c;但是除了两类&#xff1a;Filter和Servlet无法使用自动注入属性。&#xff08;因为这两个归Web容器管理&#xff09;可以用init&#xf…
阅读更多...
关于工作的选择之软件开发还是软件维护的建议

关于工作的选择之软件开发还是软件维护的建议

今天是周六休息&#xff0c;好可爱的双休日啊。下周一出差去四平&#xff0c;要和我们单位另外2名工程师一起去给四平的一个公司安装调试一个机房的设备&#xff0c;大概需要三天的时间吧。昨天晚上去个朋友家做客&#xff0c;朋友他侄子大学是学计算机软件的&#xff0c;今年刚…
阅读更多...
Mybatis：resultMap的使用总结

Mybatis：resultMap的使用总结

From: https://www.cnblogs.com/kenhome/p/7764398.html Mybatis的介绍以及使用&#xff1a;http://www.mybatis.org/mybatis-3/zh/index.html resultMap是Mybatis最强大的元素&#xff0c;它可以将查询到的复杂数据&#xff08;比如查询到几个表中数据&#xff09;映射到一个…
阅读更多...
NSOperation, NSOperationQueue 原理探析

NSOperation, NSOperationQueue 原理探析

通过GNUstep的Foundation来尝试探索下NSOperation&#xff0c;NSOperationQueue 示例程序 写一个简单的程序 - (void)viewDidLoad { [super viewDidLoad]; // Do any additional setup after loading the view, typically from a nib. [self configurationQueue]; LDNSOperatio…
阅读更多...
MyBatis总结六：resultMap详解(包含多表查询)

MyBatis总结六：resultMap详解(包含多表查询)

From: https://www.cnblogs.com/Alex-zqzy/p/9296039.html 简介&#xff1a;　　 MyBatis的每一个查询映射的返回类型都是ResultMap&#xff0c;只是当我们提供的返回类型属性是resultType的时候&#xff0c;MyBatis对自动的给我们把对应的值赋给resultType所指定对象的属性&a…
阅读更多...
object c 快速构建对象

object c 快速构建对象

__block NSNumber *capacity (0);
阅读更多...
mysql语句添加索引

mysql语句添加索引

1.PRIMARY KEY&#xff08;主键索引&#xff09; mysql>ALTER TABLE table_name ADD PRIMARY KEY ( column ) 2.UNIQUE(唯一索引) mysql>ALTER TABLE table_name ADD UNIQUE (column ) 3.INDEX(普通索引) mysql>ALTER TABLE table…
阅读更多...
最新文章

Copyright @ 2022~2023