最新文章列表

activemq发布订阅模式消息

activemq发布订阅模式消息 import javax.jms.DeliveryMode; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactor ...
zw7534313 评论(0) 有397人浏览 2020-04-29 10:04

activemq点对点消息传送

activemq点对点消息传送 消息中间件顾名思义实现的就是在两个系统或两个客户端之间进行消息传送 ActiveMQ是一种开源的基于JMS(Java Message Servie)规范的一种消息中间件的实现 ActiveMQ常被应用与系统业务的解耦,异步消息的推送,增加系统并发量,提高用户体验。 bin/activemq start AcitveMQ的数据传送流程: proceder-&g ...
zw7534313 评论(0) 有538人浏览 2020-04-29 09:56

mq预取机制

  总括:   预取时生产者向消费者推预取的数量,消费完后再给,不消费玩不给(计划经济)(批量给相应的消费者)   预取为0时消费者主动获 ...
y806839048 评论(0) 有550人浏览 2019-11-20 10:13

给女朋友讲ActiveMQ是啥?

欢迎访问个人博客:blog.ouyangsihai.cn 1 ActiveMQ是啥 ActiveMQ 就是一个消息中间件,市面上现在有很多的消息中间件开源产品,比如,RocketMQ、RabbitMQ、Kafka等。 拿一个简单的比喻来说,消息中间件就是一个中转站,在程序中加的一个中转站,有了这样一个类似快递的存储站点,可以大大的减轻物流的压力,而对应到程序中,也就是减轻了程序的压力。 ...
SIHAIloveYAN 评论(0) 有1014人浏览 2019-08-26 10:48

ActiveMQ与HA架构(master/slave)ActiveMQ与HA架构(master/slave)

   HA(高可用性)几乎在所有的架构中都需要有一定的保证,在生产环境中,我们也需要面对broker失效、网络故障等各种问题,ActiveMQ也不例外。activeMQ ...
y806839048 评论(0) 有643人浏览 2019-01-22 15:55

activemq多群负载均衡

                                                                       图一    图一说明:    1、集群一包含3个队列:Amq1、Amq2、Amq3;集群二包含2个队列:Bmq1、Bmq2    2、生产者一生产的消息可以同时发送到群集1、集群2,生产者二也一样    3、消费者一可以同时从集群1、 ...
y806839048 评论(0) 有682人浏览 2018-12-25 15:50

activemq单集群--伪集群和主从高可用使用

一、本文目的         介绍如何在同一台虚拟机上搭建高可用的Activemq服务,集群数量包含3个Activemq,当Activemq可用数>=2时,整个集群可用。         本文Activemq的集群数量为3个,分别命名为mq1,mq2,mq3  高可用的原理:  HA(高可用性)几乎在所有的架构中都需要有一定的保证,在生产环境中,我们也需要面对broker失 ...
y806839048 评论(0) 有619人浏览 2018-12-25 15:48

activemq多个集群用zk(单个)+networkconnect(集群之间)

  多个集群用zk(单个)+networkconnect(集群之间)   主要思想 mq选举由zk完成   zk可以完成自己的选主,在mq结合zk的时候zk通过节点排他锁的特性---谁 ...
y806839048 评论(0) 有599人浏览 2018-12-25 15:45

测试ActiveMQ主从复制

前天搭建了一个避免单点故障的基于zokeeper和leveldb的store。昨天测过了,kill掉Master,客户端确实是可以自动切换到被新推举出来的broker。但是消息是否也被复制过去了。会不会造成消息的丢失还需要测试一下。 测试流程 1.编写Sender和Receiver代码,通过客户端配置failover 进行一次正常的消息的发送和收,确保消息的传递是正常的。 2.通过Sender发 ...
y806839048 评论(0) 有504人浏览 2018-12-25 15:44

ActiveMQ多个消费者消费不均匀问题

先上图       如果客户端处理很慢的话,Broker会在之前发送消息的反馈之前,继续发送新的消息到客户端。如果客户端依旧很慢的话,没有得到确 ...
y806839048 评论(0) 有778人浏览 2018-11-13 18:14

消息总线真的能保证幂等?

一、缘起 如《消息总线消息必达》所述,MQ消息必达,架构上有两个核心设计点: (1)消息落地 (2)消息超时、重传、确认  
y806839048 评论(0) 有488人浏览 2018-10-25 17:33

activemq修改jvm大小

ActiveMQ内存设置 启动脚本:activemq的内存大小来自环境变量 # Set jvm memory configuration       if [ -z "$ACTIVEMQ_OPTS_MEMORY" ] ; then         ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx1G"     fi ------------ ...
dkw19860421 评论(0) 有2180人浏览 2018-10-19 17:10

ActiveMQ入门例子简单易懂

首先下载ActiveMQ:http://activemq.apache.org/download.html 在windows下启动服务:activemq.bat start 然后进入admin管理页面:http://127.0.0.1:8161/admin/ 账号和密码为:admin/admin 账号可以配置的在conf/users.properties import javax.jms. ...
qqq244078468 评论(0) 有589人浏览 2018-07-31 15:24

activemq和jdk版本对应关系

MQ版本号         Build-Jdk 依赖JDK apache-activemq-5.0.0 1.5.0_12 1.5+ apache-activemq-5.1.0 1.5.0_12 1.5+ apache-activemq-5.2.0 1.5.0_15 1.5+ apache-activemq-5.3.0 1.5.0_17 1.5+ apache-activemq-5.4.0 1.5.0 ...
dkw19860421 评论(0) 有2846人浏览 2018-06-14 16:57

activemq之高级特性

1.异步发送 消息生产者使用持久(persistent)传递模式发送消息的时候,Producer.send() 方法会被阻塞,直到 broker 发送一个确认消息给生产者,这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称为同步发送。但有一个例外,当发送方法在一个事物上下文中时,被阻塞的是 commit 方法而不是 send 方法。 ...
y806839048 评论(0) 有749人浏览 2018-05-16 16:13

ActiveMQ消息传送机制以及ACK机制详解

 AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全性,还要提供额外的手段来确保消 ...
y806839048 评论(0) 有1109人浏览 2018-05-16 16:08

activemq ack机制

  1,同步,异步ack---消费端,服务端 2,ack立即确认,ack在优化的情况下阈值确认 3,ack模式,类型---重发,删除时机         发送端:   1, ...
y806839048 评论(0) 有998人浏览 2018-05-16 16:07

activemq Unrecognized Windows Sockets error: 10106: Socket creation failed

30-Nov-2017 22:45:52.892 严重 [main] org.apache.catalina.core.StandardServer.await StandardServer.await: create[localhost:8005]: java.net.SocketException: Unrecognized Windows Sockets error: 10106: cre ...
zqs520 评论(0) 有934人浏览 2018-01-16 17:27

activemq配置

<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information re ...
annan211 评论(0) 有782人浏览 2017-11-03 17:51

最近博客热门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