Menu

  • Home
  • Work
    • Java
    • Go
    • C
    • C++
    • JavaScript
    • PHP
    • Python
    • Architecture
    • Others
      • Network
      • GIS
      • XML
      • Perl
      • Ruby
      • Lua
      • RE
      • IoT
      • Math
      • Graphic
    • OS
      • Linux
      • Windows
      • Mac OS X
    • Cloud
      • Virtualization
      • IaaS
      • PaaS
      • BigData
    • Database
      • MySQL
      • Oracle
    • Mobile
      • Android
      • IOS
    • Web
      • HTML
      • CSS
  • Life
    • Cooking
    • Travel
    • Gardening
  • Gallery
  • Video
  • Music
  • Essay
  • Home
  • Work
    • Java
    • Go
    • C
    • C++
    • JavaScript
    • PHP
    • Python
    • Architecture
    • Others
      • Network
      • GIS
      • XML
      • Perl
      • Ruby
      • Lua
      • RE
      • IoT
      • Math
      • Graphic
    • OS
      • Linux
      • Windows
      • Mac OS X
    • Cloud
      • Virtualization
      • IaaS
      • PaaS
      • BigData
    • Database
      • MySQL
      • Oracle
    • Mobile
      • Android
      • IOS
    • Web
      • HTML
      • CSS
  • Life
    • Cooking
    • Travel
    • Gardening
  • Gallery
  • Video
  • Music
  • Essay

Tag Archives: JMS

Java

Spring对JMS的支持

简介

Spring 提供了JMS的集成,简化JMS的使用,提供的API封装类似于Spring的JDBC集成。

JMS的功能大体上分为两类——接收、发送消息。Spring提供了:

  1. JmsTemplate来完成消息的发送、同步接收
  2. 消息监听器容器(message li…
阅读全文
2 years ago
0
Work

ActiveMQ学习笔记

MOM简介
MOM简介

中间件是一类连接软件组件和应用的计算机软件,它包括一组服务。 以便于运行在一台或多台机器上的多个软件通过网络进行交互。该技术所提供 的互操作性,推动了一致分布式体系架构的演进,通常用于支持并简化 那些复杂的分布式应用程序。

所谓面向消息的…

阅读全文
3 years ago
0
Java

ActiveMQ知识集锦

常见问题
Setting clientID on a used Connection is not allowed

与Spring DMLC集成,进行持久化订阅时,会报此错误,报错的根源是:

ActiveMQConnection.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@Override
public void setClientID(String newClientID) throws JMSException {
    checkClosedOrFailed();
    // false
    if (this.clientIDSet) {
        throw new IllegalStateException("The clientID has already been set");
    }
    // true
    if (this.isConnectionInfoSentToBroker) {
        // 不允许在“已经使用”的连接上执行设置clientID的操作
        throw new IllegalStateException("Setting clientID on a used Connection is not allowed");
    }
 
    this.info.setClientId(newClientID);
    this.userSpecifiedClientID = true;
    ensureConnectionInfoSent();
}

可以看到,状态isConnectionInfoSentToBroker变为true后,就不能再设置ClientID,修改此字段值的,只…

阅读全文
3 years ago
0
Java

基于JMS的ActiveMQ Java客户端示例

JMS生产者:
Producer.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package cc.gmem.demo.amq.client;
 
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.ActiveMQConnectionFactory;
 
 
 
public class Producer
{
 
    private ActiveMQConnectionFactory factory;
 
    public Producer( String brokerHost, int brokerPort )
    {
        factory = new ActiveMQConnectionFactory( "tcp://" + brokerHost + ":" + brokerPort );
    }
 
    public void sendMsgToQueue( String queueName, String msg ) throws JMSException
    {
        Connection connection = null;
        try
        {
            //如果代理启用身份验证,这里需要指定用户、密码参数
            connection = factory.createConnection();
            connection.start();
            //创建会话时有事务和确认选项
            Session session = connection.createSession( false, Session.AUTO_ACKNOWLEDGE );
            //如果代理上没有队列,则创建,否则,直接使用
            Destination dest = session.createQueue( queueName );
            //创建消息生产者
            MessageProducer producer = session.createProducer( dest );
            //设置消息是否持久化
            producer.setDeliveryMode( DeliveryMode.NON_PERSISTENT );
            //创建一个文本消息
            TextMessage message = session.createTextMessage( msg );
            producer.send( message );
        }
        finally
        {
            connection.close();
        }
    }
}
JMS消费者:
Consumer.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package cc.gmem.demo.amq.client;
 
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
 
import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
 
public class Consumer
{
 
    private static final Logger       LOGGER = LoggerFactory.getLogger( Consumer.class );
 
 
    private ActiveMQConnectionFactory factory;
 
    public Consumer( String brokerHost, int brokerPort )
    {
        factory = new ActiveMQConnectionFactory( "tcp://" + brokerHost + ":" + brokerPort );
    }
 
 
    public String reveiveMsgFromQueue( String queueName ) throws JMSException
    {
        Connection connection = null;
        try
        {
            //如果代理启用身份验证,这里需要指定用户、密码参数
            connection = factory.createConnection();
            connection.start();
            //创建会话时有事务和确认选项,如果确认选项为:SESSION_TRANSACTED,则必须启用事务
            Session session = connection.createSession( true, Session.SESSION_TRANSACTED );
            //如果代理上没有队列,则创建,否则,直接使用
            Destination dest = session.createQueue( queueName );
            //创建消息生产者
            MessageConsumer consumer = session.createConsumer( dest );
            //等待队列里面有消息可消费,最多1秒,超时返回NULL
            long timeout = 1000;
            TextMessage msg = (TextMessage) consumer.receive( timeout );
            String recMsg = msg == null ? null : msg.getText();
            //如果设置:Session.CLIENT_ACKNOWLEDGE,则必须手工确认:msg.acknowledge()
            session.commit();//如果设置:Session.SESSION_TRANSACTED,则必须提交或者回滚
            return recMsg;
        }
        finally
        {
            connection.close();
        }
    }
 
}
结合Spring使用,配置文件示例 监听器实现类示例 阅读全文
3 years ago
0

Recent Posts

  • Ansible学习笔记
  • InfluxDB学习笔记
  • Logback学习笔记
  • 使用Eclipse Memory Analyzer分析JVM堆Dump
  • 基于Rook的Kubernetes存储方案

Recent Comments

  • cesium编程入门(十)优秀资源 | cesium中文网 on Cesium学习笔记
  • Alex on Cesium学习笔记
  • tritont on Cesium学习笔记
  • Alex on 基于Kurento搭建WebRTC服务器
  • suzhq on 基于Kurento搭建WebRTC服务器
ABOUT ME

汪震 | Alex Wong

江苏淮安人,现居北京,热爱软件技术,努力成为一名优秀的全栈工程师。

Email:gmemjunk@gmem.cc@me.com

ABOUT GMEM

绿色记忆是我的个人网站,域名gmem.cc中G是Green的简写,MEM是Memory的简写,CC则是我的小天使彩彩名字的简写。

我在这里记录自己的工作与生活,同时和大家分享一些编程方面的知识。

GMEM HISTORY
v2.00:微风
v1.03:单车旅行
v1.02:夏日版
v1.01:未完成
v0.10:彩虹天堂
v0.01:阳光海岸
LOCAL WEATHER
MIRROR INFO
Meta
  • Log in
  • Entries RSS
  • Comments RSS
  • WordPress.org
Recent Posts
  • Ansible学习笔记
    简介 Ansible是一个自动化IT工具,能够配置系统、部署软件、编排复杂的IT任务(例如CD、零停机滚动更新 ...
  • InfluxDB学习笔记
    简介 InfluxDB是一个用于存储和分析时间序列数据的开源数据库。它的特性包括: 支持HTTP接口 ...
  • Logback学习笔记
    简介 Logback的目标是作为Log4j的继任者。Logback使用模块化的架构,主要分为三个部分:logb ...
  • 使用Eclipse Memory Analyzer分析JVM堆Dump
    简介 Eclipse Memory Analyzer(MAT)是一个图形化的Java堆分析工具,速度快且特性丰 ...
  • 基于Rook的Kubernetes存储方案
    简介 Rook是专用于Cloud-Native环境的文件、块、对象存储服务。它实现了一个自我管理的、自我扩容的 ...
  • OpenResty学习笔记
    简介 OpenResty是一个基于Nginx+Lua的Web运行环境,它打包了标准的 Nginx 核心,很多的 ...
  • 露天厨房 乡村宴席
       

  • 基于Calico的CNI
    什么是Calico Calico为容器或虚拟机提供安全的网络连接,它创建一个扁平化的第3层网络,为每个节点分配 ...
  • Kong学习笔记

  • 羽田裕美.明日を夢見て

  • gRPC学习笔记
    简介 gRPC是Google开源的高性能RPC框架,它在HTTP/2的基础之上实现。gRPC能高效的连接数据中 ...
  • Protocol Buffers初探
    简介 ProtoBuf是Google提出的语言中立、平台无关、可扩展的数据序列化协议。比起XML、JSON等格 ...
  • Apache Shiro学习笔记
    简介 Shiro是一个支持身份验证、授权、加密、会话管理的Java安全框架。Shiro的API很简单,比Spr ...
  • ElasticSearch学习笔记
    简介 Elasticsearch是一个基于Apache Lucene的全文检索和分析引擎,可以扩容到上百台服务 ...
TOPLINKS
  • Zitahli's blue 86 people like this
  • 汪静好 61 people like this
  • 梦中的婚礼 51 people like this
  • 那年我一岁 36 people like this
  • 为了爱 27 people like this
  • 小绿彩 26 people like this
  • 汪昌博 people like this
  • 彩虹姐姐的笑脸 24 people like this
  • 2013年11月香山 10 people like this
  • 2013年7月秦皇岛 6 people like this
  • 2013年6月蓟县盘山 5 people like this
  • 2013年2月梅花山 2 people like this
  • 2013年淮阴自贡迎春灯会 3 people like this
  • 2012年镇江金山游 1 people like this
  • 2012年徽杭古道 9 people like this
  • 2011年清明节后扬州行 1 people like this
  • 2008年十一云龙公园 5 people like this
  • 2008年之秋忆 7 people like this
  • 老照片 13 people like this
  • 火一样的六月 16 people like this
  • 发黄的相片 3 people like this
  • PhoneGap学习笔记 32 people like this
  • NaCl学习笔记 32 people like this
  • 使用Oracle Java Mission Control监控JVM运行状态 29 people like this
  • Cesium学习笔记 26 people like this
Tag Cloud
ActiveMQ AngularJS Apache AspectJ BigData BOOST CDT Chrome Command Cordova Coroutine CXF Cygwin Django Docker Eclipse ExtJS F7 FAQ Groovy Hadoop Hibernate HTTP IntelliJ IO编程 JacksonJSON JMS jQuery JSMpeg JSON JVM K8S libvirt LLVM LOG Maven MinGW Mock MongoDB Monitoring MSE Multimedia MVC MySQL netfs Netty Nginx NIO Node.js NoSQL Oracle PDT Photoshop PHP Porting RPC Scheduler SNMP Spring SSL STOMP svn Tomcat TSDB Ubuntu WebGL WebRTC WebService WebSocket wxWidgets XDebug XML XPath XRM ZooKeeper 单元测试 学习笔记 实时处理 容器化 并发编程 彩虹姐姐 性能调优 文本处理 新特性 网络编程 视频监控 设计模式 远程调试 配置文件 齐塔莉
Recent Comments
  • cesium编程入门(十)优秀资源 | cesium中文网 on Cesium学习笔记
  • Alex on Cesium学习笔记
  • tritont on Cesium学习笔记
  • Alex on 基于Kurento搭建WebRTC服务器
  • suzhq on 基于Kurento搭建WebRTC服务器
  • Manpo on 基于Kurento搭建WebRTC服务器
  • Alex on 基于Kurento搭建WebRTC服务器
  • Manpo on 基于Kurento搭建WebRTC服务器
  • Alex on 基于Kurento搭建WebRTC服务器
  • Alex on 基于Kurento搭建WebRTC服务器
©2005-2018 Gmem.cc | Powered by WordPress