- 浏览: 156523 次
- 性别:
- 来自: 魔都
最新评论
-
renzhengzhi:
mybatis的这个批量insert为什么不是在一个事务里?
使用Mybatis做批量插入 -
forlab:
花架构威武吧唧,一统江湖
Eclipse插件之Findbugs -
恋上你的味道:
花家狗V587 神功盖屎 一桶浆糊
Netty+Tomcat热部署端口占用解决办法 -
hekuilove:
宁帅陈 写道你好,我想通过java程序获取@当前登录用户的人员 ...
新浪微博API开发流程 -
宁帅陈:
你好,我想通过java程序获取@当前登录用户的人员以及信息,怎 ...
新浪微博API开发流程
1、TextMessage
发送部分
接收部分
2、BytesMessage
发送部分
接收部分
发送部分
package org.quinn.activemq; 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 SendMessage { public static void main(String[] args) { ConnectionFactory factory; //连接工厂 Connection connection;//jms连接 Session session;//发送、接收线程 Destination destination;//消息目的地 MessageProducer producer;//消息发送者 factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { connection = factory.createConnection(); connection.start(); session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("FirstQueue"); producer = session.createProducer(destination); producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); //是否为持久化 ,NON_PERSISTENT非持久化 ,PERSISTENT持久化 for (int i = 11; i < 13; i++) { String msg = "第" + i + "次发送消息"; TextMessage textMessage = session.createTextMessage(msg); producer.send(textMessage); } session.commit(); } catch (JMSException e) { e.printStackTrace(); } } }
接收部分
package org.quinn.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; public class ReceivedMessage { /** * @param args */ public static void main(String[] args) { ConnectionFactory factory; Connection connection = null; Session session; Destination destination; MessageConsumer consumer; factory = new org.apache.activemq.ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { connection = factory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("FirstQueue"); consumer = session.createConsumer(destination); while (true) { TextMessage textMessage = (TextMessage) consumer.receive(); if (textMessage != null){ System.out.println(textMessage.getText()); } Thread.sleep(1000); } } catch (JMSException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } finally { try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } }
2、BytesMessage
发送部分
package org.quinn.activemq; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import javax.jms.BytesMessage; 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 org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; public class SendBytesMessage { public static void main(String[] args) { ConnectionFactory factory; //连接工厂 Connection connection;//jms连接 Session session;//发送、接收线程 Destination destination;//消息目的地 MessageProducer producer;//消息发送者 factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { connection = factory.createConnection(); connection.start(); session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("FirstQueue"); producer = session.createProducer(destination); producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); BytesMessage bytesMessage = session.createBytesMessage(); File fil = new File("C:\\Users\\WS-SH-L1051\\Desktop\\a.txt"); InputStream is = new FileInputStream(fil); byte by[] = new byte[is.available()]; is.read(by); bytesMessage.writeBytes(by); producer.send(destination, bytesMessage); is.close(); session.commit(); } catch (JMSException e) { e.printStackTrace(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
接收部分
package org.quinn.activemq; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStream; 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.Session; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.command.ActiveMQBytesMessage; public class ReceivedBytesMessage { /** * @param args */ public static void main(String[] args) { ConnectionFactory factory; Connection connection = null; Session session; Destination destination; MessageConsumer consumer; factory = new org.apache.activemq.ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { connection = factory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("FirstQueue"); consumer = session.createConsumer(destination); while (true) { Message msg = consumer.receive(); if(msg instanceof ActiveMQBytesMessage){ ActiveMQBytesMessage bytesMessage = (ActiveMQBytesMessage) msg; if (bytesMessage != null){ byte []bt = new byte[(int) bytesMessage.getBodyLength()]; bytesMessage.readBytes(bt); File fil =new File("C:\\Users\\WS-SH-L1051\\Desktop\\b.txt"); if(!fil.exists()){ fil.createNewFile(); } OutputStream os = new FileOutputStream(fil); os.write(bt); os.close(); } } Thread.sleep(1000); } } catch (JMSException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } }
发表评论
-
JVM相关笔记
2019-01-30 21:19 4651、检查死锁 jps -v [查看所有Java进 ... -
Git常用命令记录
2019-01-08 11:20 498强制更新 git log git reset --hard ... -
Netty+Tomcat热部署端口占用解决办法
2015-06-13 17:32 8181在eclipse使用maven deploy (tomcat: ... -
MAVEN+TOMCAT7、8的Deploy配置
2015-06-13 13:46 41、配置好conf/tomcat-users.xml,加入如下 ... -
javascript之HashMap
2015-04-16 11:23 1171用法 var map = new HashMap(); ... -
发现面向对象的美之抽象
2014-09-19 11:56 0很多开发者在面试的时候恐怕都问过或者被问过,面向对象的几大特性 ... -
ActiveMQ初级教程
2014-05-20 18:07 2655MQ的思想其实和连接池差不多,只不过一个是队列,一个是多线程。 ... -
Mybatis批量插入Oracle、MySQL
2014-05-19 16:09 5166要做批量插入数据库, ... -
UDP通讯协议
2014-02-20 21:01 1184在做手机和服务端通讯时,UDP是其中可用协议之一。不过UDP的 ... -
JBOSS7配置JDNI
2014-02-13 21:52 12601、配置jar包 在jboss7的安装目录modules下建立 ... -
自定义DWR拦截器
2013-06-04 19:07 4493使用DWR和其它mvc框架混用时(如struts和spring ... -
Eclipse+TOMCAT工程如何deploy在webapps文件夹
2013-02-05 20:10 4756Eclipse集成Tomcat发布工程的时候,有时候项目发布不 ... -
根据时间的复杂统计
2012-12-07 18:24 1262客户的需求往往是各种各样的,本人在开发系统的时候遇到一个比较复 ... -
MySQL UTF-8中文排序
2012-06-15 16:08 2847假如在MySQL的表中有一列字段是中文,需要根据该字段从a-z ... -
关于:the last packet sent successfully to the server was 0 milliseconds ago
2012-04-20 10:11 2672最近老是出现个问题,早上以来公司登录公司的后台业务系统(由我是 ... -
使用Mybatis做批量插入
2012-03-30 19:50 30516最近有个需求,将excel的数据导入的数据库的这个一个操作。 ... -
jquery ajax parseerror问题
2012-03-03 12:32 3845以前都是用ajax做一些简单的东东,很少用ajax做查询。今日 ... -
过滤器chain.doFilter(req, resp);抛异常java.lang.IllegalArgumentException
2012-02-08 21:35 2598今天在开发中遇到一个错误 org.springframew ... -
关于maven工程内存溢出解决办法
2012-01-04 14:17 2141在看maven in action的时候意外发现我们项目中经常 ...
相关推荐
activemq 通过ajax发送接收消息简单例子
activeMQ的测试工具,用于发送和接收activeMQ消息,jar包形式的,安装完jdk之后用java -jar xxx.jar命令运行
实现了ActiveMQ的初步封装,比较适合新手入门学习,简单明了
这是我精力整理的ActiveMQ发送和接收protobuf协议消息的实例。 也对ActiveMQ进行了简化封装,也配置了自动重连机制,亲测可用!
springboot集成activemq实现消息接收demo
Android基于MQTT协议利用ActiveMQ发送消息给Android端接收,属于长连接那种,类似Socket通信
SpringBoot+ActiveMq+MQTT实现消息的发送和接收 后台消费者、生产者、消息发送接口、发送消息业务类等相关配置
activeMQ的发送消息后接收者返回信息
本代码关于activemq-cpp的核心代码参考的chenxun2009的博客园,其他部分包括:从配置文件中读取消息通道,过滤条件等信息。
springboot整合ActiveMQ源码,适合范围消息队列入门小伙伴,对ActiveMQ消息队列不太了解,不知道如何发送消息,接收消息可以围观。
使用C# 下activemq 接收数据流的例子
今天小编就为大家分享一篇python 发送和接收ActiveMQ消息的实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
activemq 发送,接受,监控样例程序
NULL 博文链接:https://sswh.iteye.com/blog/1974169
RetailSystem包含消息生产者Producer,BankSystem包含消息接收者Consumer和Java调用C++的中间类DLL,dll3为Java方法在C++下的实现.
接受ActiveMQ信息,通过openfire公告发送给指定用户,xml串解析
WebSocket协议接收ActiveMQWebSocket协议接收ActiveMQWebSocket协议接收ActiveMQWebSocket协议接收ActiveMQ
activeMq的使用以及简介,还有短信功能的代码逻辑分析