关键代码片段 1. 循环几次发送几次 2. selectOneMessageQueue 返回与上一个broker不同名的broker 3. timesTotal 是brokersSent 数组 4. 某broker发送失败时,如果想要重试其他broker,需要把retryAnotherBrokerW ...
分类:
其他好文 时间:
2016-08-06 08:25:40
阅读次数:
910
1.1. 控制台使用 RocketMQ 提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker 等信息的管理 登录控制台 首先进入RocketMQ 工程,进入/RocketMQ/bin 在该目录下有个mqadmin 脚本 查看帮助 在mqadmin 下可以查看有哪些命令 sh mqad ...
分类:
其他好文 时间:
2016-08-06 08:24:07
阅读次数:
4635
character (`) A backquote or backtick. echo 'date' date echo `date` 2015年 07月 03日 星期五 16:11:13 CST jstat -gc `ps aux | grep java | awk '/broker/ {prin ...
分类:
其他好文 时间:
2016-08-06 08:15:03
阅读次数:
122
目前业界有很多MQ产品,我们作如下对比: RabbitMQ 是使用Erlang编写的一个开源的消息队列,本身支持很多的协议:AMQP,XMPP, SMTP, STOMP,也正是如此,使的它变的非常重量级,更适合于企业级的开发。同时实现了一个经纪人(Broker)构架,这意味着消息在发送给客户端时先在 ...
分类:
其他好文 时间:
2016-08-04 10:22:37
阅读次数:
116
Rabbitmq 初识rabbitmq RabbitMQ是流行的开源消息队列系统,用erlang语言开发。RabbitMQ是AMQP(高级消息队列协议)的标准实现。如果不熟悉AMQP,直接看RabbitMQ的文档会比较困难。不过它也只有几个关键概念,这里简单介绍 几个概念说明: Broker:简单来 ...
分类:
其他好文 时间:
2016-08-02 15:02:48
阅读次数:
208
Service Broker needs to access the master key in the database ‘BRM_TEST’. Error code:32. The master key has to exist and the service master key encryp ...
分类:
数据库 时间:
2016-07-23 15:04:01
阅读次数:
280
Service Broker:多服务器单信息传递,大小写敏感 组成: Message:信内容,为便于区分保证唯一性,信息的前缀用域名好一些。 Contracts:信头,组合message及message由哪边发送,发起者或者接收者 Queue:信封,收到的信息存储的位置 建立方式: 1,定义 SER ...
分类:
其他好文 时间:
2016-07-23 15:00:12
阅读次数:
211
Redis与Java标签 : Java与NoSQL
Redis(REmote DIctionary Server) is an open source (BSD licensed), in-memory data structure store, used as database, cache and message broker. It supports data structures suc...
分类:
编程语言 时间:
2016-07-23 10:38:52
阅读次数:
458
1. 下载二进制文件并解压,并修改 broker.id 的值 2. 开启zookeeper server 和 kafka server 3. 创建一个topic 然后 查看创建的topic,之后不需要重复创建 4. 发送一些message 5. 启动一个consumer ...
分类:
其他好文 时间:
2016-07-20 19:36:28
阅读次数:
132
本文转发自Jason’s Blog,原文链接 http://www.jasongj.com/2015/06/08/KafkaColumn3 摘要 本文在上篇文章基础上,更加深入讲解了Kafka的HA机制,主要阐述了HA相关各种场景,如Broker failover,Controller failov ...
分类:
其他好文 时间:
2016-07-15 20:39:31
阅读次数:
183