博客首页 → ActiveMQ

最新文章列表

Broker启用安全认证，需要用户名和密码验证

Broker需要在配置文件中开安全认证，客户端或者其他Broker连接时，需要通过对应的用户名和密码来访问，默认没有安全认证。配置样例如下： （1）、指定加密的环境变量： 删除 <!-- Allows us to use system properties as variables in this configuration file --> <bean class=&qu ...
ActiveMQAuthorization 
can_do 评论(0) 有692人浏览 2015-10-16 17:12

用于处理日志的分布式消息系统Kafka（吞吐量高于ActiveMQ和RabbitMQ）

1、几个重要概念 1.1 topic 1.2 broker 1.3 consumer pull message，不是broker push消息给消费者，这样做的另一个特点是，消费者可以绕过当前偏移位的消息，去消费其他偏移位上的消息。和传统的方式不一样。 1.4 consumer可以订阅1个或者多个topic broker不记录消息的ID（或者说没有消息ID），通过offset和消息的大小来定位消息。 ...
activemqkafkaMQ 
can_do 评论(0) 有1188人浏览 2015-10-16 17:11

关于ActiveMQ的点点滴滴

>>Producer flow-control Note that, since the introduction of the new file cursor in ActiveMQ 5.x, non-persisted messages are shunted into the temporary file store to reduce the amount of memory u ...
activemqjms 
can_do 评论(0) 有749人浏览 2015-10-15 17:32

消息中间件（2）-ActiveMq & Spring 技术集成

一、为什么需要spring + activeMq 集成？ 1、原生的JMS使用起来，太繁琐，需要封装很多层才能在正式代码中使用， 2、activemq一套开源的JMS实现方案，实现了服务端和客户端，开箱即用 3、spring一整套组件，直接拿来主义   二、实现步骤 1、开启activemq服务端 直接从官网下载 http://activemq.apache.org/，开箱 ...
JMSactivemqspring消息中间件 
haoran_10 评论(0) 有2815人浏览 2015-10-15 16:00

AMQ中池化连接工厂（PooledConnectionFactory）的用法和机制

>>代码示例如下： import javax.jms.JMSException; import javax.jms.MessageConsumer; import com.cnd.mq.AMQSession; import com.cnd.mq.command.AMQQueue; import com.cnd.mq.jms.pool.PooledSession; import com ...
ActiveMQconnectionPool 
can_do 评论(0) 有2938人浏览 2015-09-30 09:54

MQ相关

关键特征： 1、可靠性（一般通过消息持久化实现，可持久化到磁盘、数据库等，没有持久化的可靠性如何保证） 2、优先级（0-9，这个是JMS的规范） 3、节点间组网（分布式特性，实现消息跨节点路由） 4、消息模型（PTP || Pub/Sub，这个是JMS的规范） 性能指标： 4、高吞吐量 5、低延迟 1、AMQ是完全遵循JMS1.1规范的；有多种协议支持：openwire（nio）、stomp、mq ...
jmsActiveMQ 
can_do 评论(0) 有1030人浏览 2015-09-30 09:50

ActiveMQ中由【Channel was inactive for too(30000) long】想到的

【日志】警告信息如下： //////////begin////// 2014-01-15 16:39:46,030 | WARN  | Transport Connection to: tcp://10.88.112.165:58072 failed: com.cnd.emq.transport.InactivityIOException: Cha nnel was inactive for too ...
activemqtcp 
can_do 评论(0) 有3357人浏览 2015-09-25 21:38

关于AMQ中的事务

（1）、JMS事务和XA事务真正唯一的不同之处在于，XA事务中，在Prepare阶段，broker必须写所有接收到的命令（如：发消息或者应答消息）到持久化存储中，目的是broker以后能够正确的进行恢复操作。 （2）、【TransactionStore】事务存储进行事务处理，它会缓存所有的消息和应答，直到发生commit或者rollback操作；除了存储消息外，事务存储还会抑制消息的分发，直到se ...
ActiveMQDT 
can_do 评论(0) 有597人浏览 2015-09-24 14:00

关于Failover协议的使用

1、Failover是所有协议之上的一个协议，所以其用法如下： failover:(tcp://localhost:61616,tcp://10.88.112.165:61617)?randomize=false 或者 failover:()?randomize=false&updateU ...
ActiveMQfailover 
can_do 评论(0) 有1955人浏览 2015-09-24 13:59

关于MQ调优（续）

>>This optimal ratio depends on many factors including:   >>>the JDK version and operating system used   >>>whether or not the producers and consumers are running in the same JV ...
ActiveMQjava tuning 
can_do 评论(0) 有620人浏览 2015-09-23 13:32

MQ中传输大消息时出现的OOM问题

java.lang.OutOfMemoryError: Java heap space Dumping heap to java_pid5328.hprof ... Heap dump file created [529688434 bytes in 4.197 secs] Exception in thread "EMQ Broker[broker-cnd] Scheduler" ...
ActiveMQOOM 
can_do 评论(0) 有1724人浏览 2015-09-22 15:49

MQ出现OOM问题之二

【问题】 MQ长期运行后，出现老代GC不掉的现象分析。 通过HA工具分析后，发现对象TransportConnection占用绝对部分heap空间。 问题分解：实际可以归结为两个方面的问题，如下： 1、VMTransport的建立是由网桥建立动作触发的；即【VMTransport】对象在内存中的增加； 2、VMTransport能否被回收和内存中该对象的引用有关；即【VMTransport】对 ...
ActiveMQOOM 
can_do 评论(0) 有777人浏览 2015-09-22 15:46

AMQ中Acknowledge那些事

应答模式和transaction的关系==> 0.Session.SESSION_TRANSACTED (0) 1.Session.AUTO_ACKNOWLEDGE (1) 2.Session.CLIENT_ACKNOWLEDGE (2) 3.Session.DUPS_OK_ACKNOWLEDGE (3) 4.EMQSession.INDIVIDUAL_ACKNOWLEDGE (4) 说明：S ...
ActiveMQJMS 
can_do 评论(0) 有969人浏览 2015-09-18 11:50

记录amq的一些参数解释

createSession(paramA,paramB);paramA是设置事务的，paramB设置acknowledgment modeparamA设置为false时：paramB的值可为Session.AUTO_ACKNOWLEDGE，Session.CLIENT_ACKNOWLEDGE，DUPS_OK_ACKNOWLEDGE其中一个。paramA设置为true时：paramB的值忽略， ac ...
ApacheActiveMQ 
gao_xianglong 评论(0) 有1244人浏览 2015-09-15 17:53

ActiveMQ在Spring中异步接收消息(六)

转载请出自出处：http://eksliang.iteye.com/blog/2243158 一、概述      当调用JmsTemplate的receive()方法时，JmsTemplate会尝试从ActiveMQ中获取一个消息。如果没有 ...
JMSActiveMQSpring 
eksliang 评论(0) 有5440人浏览 2015-09-14 10:31

ActiveMQ与Spring集成（五）

转载请出自出处：http://eksliang.iteye.com/blog/2242743 在上篇文章中ActiveMQ与Spring集成在spring中我们使用ActiveMQ自带的连接工厂创建connectionFactory，在这篇文章将介绍在spring中使用ActiveMQ自己的命名空间来声明连接工厂，目的地等等！   使用Active自己的命名空间工厂，需要导入一个jar包， ...
amqactiveMQJMS 
eksliang 评论(0) 有2372人浏览 2015-09-11 16:07

ActiveMQ与Spring集成（四）

转载请出自出处：http://eksliang.iteye.com/blog/2242729 一、必须导入spring对JMS封装的包  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> < ...
spring activeMQactiveMQJMS 
eksliang 评论(1) 有4016人浏览 2015-09-11 15:11

JMS 五种消息体的发送/接收（三）

转载请出自出处：http://eksliang.iteye.com/blog/2242642 在JMS与ActiveMQ简介（一）中介绍了JMS消息的组成，由三个部分组成，head(头)、properties（属性）、body(包体)，其中body中存放要发送给接收应用程序的内容。每个消息接口特定于它所支持的内容类型。JMS为不同类型的内容提供了他们各自的消息类型，但是所有消息都派生自Mess ...
JMSActiveMQMessage 
eksliang 评论(0) 有7356人浏览 2015-09-11 10:33

JMS ActiveMQ Queue（点对点模型）实例（二）

转载请出自出处：http://eksliang.iteye.com/blog/2242495 一.使用消息队列模型发送消息至activeMQ（生产者开发）   package com.gosun.activemq; import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.Destin ...
jmsactiveMQqueue 
eksliang 评论(0) 有10063人浏览 2015-09-10 19:05

ActiveMQ（五）

今天本篇为ActiveMQ的Queue基础使用         在我看来ActvieMQ中Queue是其常用的消息发送模式，其应用性比topic远要来的广（大牛勿喷，公司业务、公司行业决定了topic方式在我接触到的项目中使用并不广泛）。     1.Topic和queue的技术特点对比   Topic Queue 中文全称 发布订 ...
ActiveMQ学习教程java 
bartholomew4 评论(0) 有749人浏览 2015-08-31 08:48

最近博客热门TAG

Apache(33931) Lucene(5053) Hadoop(5049) nginx(3449) vim(3262) GCC(2954) memcached(2625) jfreechart(1688) Django(1602) Zend(1413) ActiveMQ(1398) Grails(1374) ActiveRecord(1349) OpenSource(1236) Emacs(870) Glassfish(858) lighttpd(810) rubygems(716) GAE(631) Blend(516)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics