1、下载rocketmq包 2、解压zip包 3、编译部署 4、配置环境变量 5、启动 NameServer（每台机器都要启动） 6、启动broker（每台机器都要） 7、测试验证 1、下载rocketmq包 下载地址：http://rocketmq.apache.org/dowloading/re ...
分类：
其他好文 时间：
2019-01-31 18:17:18
阅读次数：
234
若用户使用 Java 7，那么在选择 GC 收集器时可以根据以下法则进行确认? 如果用户机器上的 CPU 资源非常充裕，那么推荐使用 CMS 收集器 这样可以充分利用多 CPU 执行并发垃圾收集 启用方法为－ :XX:+U seCurrentMarkSweepGC? 相反地，则使用吞吐量收集器，即所 ...
分类：
其他好文 时间：
2019-01-30 12:49:45
阅读次数：
736
asnpcitrix#加载citrix的powershell命令Get-BrokerHypervisorConnection#查看新connection的Uid，Uid数字Get-BrokerMachine-MachineName‘tomogroup\ctxvdi‘|Set-BrokerMachine-HypervisorConnectionUid2#根据计算机目录创建的计算机名称
分类：
其他好文 时间：
2019-01-29 13:57:41
阅读次数：
245
application.properties文件配置： #服务端口，8080被另一服务占用server.port=9090spring.activemq.broker-url=tcp://127.0.0.1:61616# 在考虑结束之前等待的时间#spring.activemq.close-time ...
分类：
编程语言 时间：
2019-01-28 12:11:51
阅读次数：
441
事务消息主要用在发送方 因为发送方 发出消息后，不能确定broker一定收到了 所以在connection上加上事务属性， 发送方感知到发送失败，可以做其他处理（比如先在数据库记上一笔，后面补发此消息） ...
分类：
其他好文 时间：
2019-01-28 00:51:53
阅读次数：
177
我们知道无论是生产者还是消费者，都需要和 RabbitMQ Broker 建立连接，这个连接就是一条 TCP 连接，也就是 Connection。 一旦 TCP 连接建立起来，客户端紧接着可以创建一个 AMQP 信道（Channel），每个信道都会被指派一个唯一的 ID。 信道是建立在 Connec ...
分类：
其他好文 时间：
2019-01-27 19:26:01
阅读次数：
772
对于一个生产者来说，在进行sendmessage的时候，需要知道这个topic应该发给哪个broker。如果没有路由信息的话，需要取注册中心，通过GET_ROUTEINTO_BY_TOPIC去注册中心拿到消息。 介绍下面具体流程之前，还是先介绍注册额中心里面路由管理者RouteInfoManager ...
分类：
其他好文 时间：
2019-01-27 19:20:19
阅读次数：
229
生产者发送消息 1、生产者连接到 RabbitMQ Broker，建立一个连接（Connection），开启一个信道（Channel） 2、生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等 3、生产者声明一个队列并设置相关属性，比如是否排他、是否持久化、是否自动删除等 4、生产者通 ...
分类：
其他好文 时间：
2019-01-27 19:18:54
阅读次数：
180
一个haservice下面有accpet和haclient分别对应客户端和服务端，grouptranserservie用来控制消息是否获取到，下面具体讲。 拿haclient举例子，在主线程做的事情 也就是在rocketmq里面，一个具体的任务就是单独分配一个线程，从而发挥多线程优势，在主线程上面休 ...
分类：
其他好文 时间：
2019-01-27 16:35:46
阅读次数：
185
在发送小消息的场景中,三个消息中间件的表现区分明显: Kafka的吞吐量高达17.3w/s,远超其他两个产品。这主要取决于它的队列模式保证了写磁盘的过程是线性IO。此时broker磁盘IO已达瓶颈。 RocketMQ也表现不俗,吞吐量在11.6w/s,磁盘IO %util已接近100%。Rocket ...
分类：
其他好文 时间：
2019-01-26 22:38:02
阅读次数：
245
