本月博客排行
年度博客排行
-
第1名
宏天软件 -
第2名
青否云后端云 -
第3名
龙儿筝 - gashero
- wallimn
- vipbooks
- wy_19921005
- benladeng5225
- fantaxy025025
- zysnba
- ssydxa219
- e_e
- sam123456gz
- javashop
- arpenker
- tanling8334
- kaizi1992
- xpenxpen
- xiangjie88
- wiseboyloves
- ganxueyun
- sichunli_030
- xyuma
- wangchen.ily
- lemonhandsome
- jh108020
- zxq_2017
- jbosscn
- Xeden
- luxurioust
- zhanjia
- lzyfn123
- forestqqqq
- ajinn
- nychen2000
- wjianwei666
- daizj
- hanbaohong
- johnsmith9th
- ranbuijj
- 喧嚣求静
- silverend
- kingwell.leng
- lchb139128
- lich0079
- kristy_yy
- jveqi
- java-007
- sunj
- yeluowuhen
最新文章列表
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 ...
activemq点对点消息传送
activemq点对点消息传送
消息中间件顾名思义实现的就是在两个系统或两个客户端之间进行消息传送
ActiveMQ是一种开源的基于JMS(Java Message Servie)规范的一种消息中间件的实现
ActiveMQ常被应用与系统业务的解耦,异步消息的推送,增加系统并发量,提高用户体验。
bin/activemq start
AcitveMQ的数据传送流程:
proceder-&g ...
给女朋友讲ActiveMQ是啥?
欢迎访问个人博客:blog.ouyangsihai.cn
1 ActiveMQ是啥
ActiveMQ 就是一个消息中间件,市面上现在有很多的消息中间件开源产品,比如,RocketMQ、RabbitMQ、Kafka等。
拿一个简单的比喻来说,消息中间件就是一个中转站,在程序中加的一个中转站,有了这样一个类似快递的存储站点,可以大大的减轻物流的压力,而对应到程序中,也就是减轻了程序的压力。 ...
activemq多群负载均衡
图一 图一说明:
1、集群一包含3个队列:Amq1、Amq2、Amq3;集群二包含2个队列:Bmq1、Bmq2
2、生产者一生产的消息可以同时发送到群集1、集群2,生产者二也一样
3、消费者一可以同时从集群1、 ...
activemq单集群--伪集群和主从高可用使用
一、本文目的
介绍如何在同一台虚拟机上搭建高可用的Activemq服务,集群数量包含3个Activemq,当Activemq可用数>=2时,整个集群可用。
本文Activemq的集群数量为3个,分别命名为mq1,mq2,mq3
高可用的原理:
HA(高可用性)几乎在所有的架构中都需要有一定的保证,在生产环境中,我们也需要面对broker失 ...
测试ActiveMQ主从复制
前天搭建了一个避免单点故障的基于zokeeper和leveldb的store。昨天测过了,kill掉Master,客户端确实是可以自动切换到被新推举出来的broker。但是消息是否也被复制过去了。会不会造成消息的丢失还需要测试一下。 测试流程
1.编写Sender和Receiver代码,通过客户端配置failover 进行一次正常的消息的发送和收,确保消息的传递是正常的。 2.通过Sender发 ...
activemq修改jvm大小
ActiveMQ内存设置
启动脚本:activemq的内存大小来自环境变量
# Set jvm memory configuration
if [ -z "$ACTIVEMQ_OPTS_MEMORY" ] ; then
ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx1G"
fi
------------ ...
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. ...
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 ...
activemq之高级特性
1.异步发送
消息生产者使用持久(persistent)传递模式发送消息的时候,Producer.send() 方法会被阻塞,直到 broker 发送一个确认消息给生产者,这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称为同步发送。但有一个例外,当发送方法在一个事物上下文中时,被阻塞的是 commit 方法而不是 send 方法。 ...
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 ...
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 ...