Hello world程序演示： 生产者： 消费者： 安全认证机制： 在activemq.xml文件中的broker节点中的末尾增加下面的内容 然后，再访问MQ时就需要认证了，在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和 ...
分类：
其他好文 时间：
2017-11-28 12:41:52
阅读次数：
183
单体架构模式下的数据库基本都是单数据库，所以应用层通过spring事务控制的本质其实就是数据库对事务的支持，没有数据库的事务支持，spring是无法提供事务功能的。通过spring实现事务的方式也有声明式事务和编程式事务两种，不管哪一种实现起来都比较简单。像一般的业务，类型下面这种方式编程就行： 1 ...
分类：
数据库 时间：
2017-11-24 00:12:38
阅读次数：
302
Kafka常用命令: Consumer##控制台发送消息./kafka-console-producer.sh --broker-list 集群IP:Port --topic topic名字./kafka-console-producer.sh --broker-list 集群IP:Port --t ...
分类：
其他好文 时间：
2017-11-16 14:23:25
阅读次数：
183
几个名词 Java消息服务(Java Message Service)是一个Java标准，定义了使用消息代理的通用API。 消息代理（message broker）：类似于邮局的作用，确保消息被投递到指定的目的地。 ActiveMQ Kafka 目的地（destination） 队列（queue,点 ...
分类：
编程语言 时间：
2017-11-14 23:26:39
阅读次数：
243
消息队列是非常基础的关键服务，为保证公司队列服务的高可用及负载均衡，现通过如下方式实现: RabbitMQ Cluster + Queue HA + Haproxy + Keepalived3台rabbitMQ服务器构建broker集群，允许2台服务器故障而服务不受影响，在此基础上，通过queue ...
分类：
其他好文 时间：
2017-11-13 17:05:10
阅读次数：
212
RocketMQ是一款分布式消息系统，最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统，满足线上海量堆积的需求，在去年捐赠给Apache开源基金会，并列为孵化项目，今年成功的正式成为了apache顶级项目；早期阿里曾经基于ActiveMQ研发的消息系统，随着业务消息的规模增大，瓶颈逐渐明显， ...
分类：
系统相关 时间：
2017-11-11 11:21:40
阅读次数：
176
kafka分区及副本在broker的分配 部分内容參考自：http://blog.csdn.net/lizhitao/article/details/41778193 以下以一个Kafka集群中4个Broker举例，创建1个topic包括4个Partition，2 Replication；数据Pro ...
分类：
其他好文 时间：
2017-11-10 16:59:29
阅读次数：
169
