| 共 11 篇文章 |
|
RabbitMQ进程结构分析与性能调优。图2 RabbitMQ进程模型。在整个系统中，存在一个tcp_accepter进程，一个rabbit_msg_store进程，有多少个队列就有多少个rabbit_amqqueue_process进程，每个客户端连接对应一个rabbit_reader和rabbit_writer进程。queue_index_embed_msgs_below：RabbitMQ 3.5版本引入了将小消息直接存入队列索引（queue_index）... 阅607 转2 评0 公众公开 16-12-21 17:58 |
记得要先用命令添加这个命令才行：[plain] view plain copy cd /usr/lib/rabbitmq/bin/ #用户名与密码[plain] view plain copy sudo rabbitmqctl add_user asdf 123456 用户设置为administrator才能远程访问[plain] view plain copy sudo rabbitmqctl set_user_tags asdf administrator sudo rabbitmqctl set_permissions -p / asdf "... 阅234 转2 评0 公众公开 16-12-21 17:24 |
rocketmq的顺序消息需要满足2点： 1.Producer端保证发送消息有序 …源代码版本是3.2.6，还是直接跑源代码。rocketmq事务消息是发生在Pro …在rocketmq里，consumer被分为2类：MQP …源代码版本是3.2.6，还是直接跑源代码，启动配置参照前面写的《简介和quick …RocketMQ是什么？引用官方描述： RocketMQ是一款分布式、队列模型 … 阅809 转1 评0 公众公开 16-01-13 21:42 |
分布式消息队列RocketMQ部署与监控（好全，带脚本）https://github.com/alibaba/RocketMQ/releases# tar xvzf alibaba-rocketmq-3.1.7.tar.gz -C /usr/local# mv alibaba-rocketmq alibaba-rocketmq-3.1.7# ln -s alibaba-rocketmq-3.1.7 rocketmq# rm alibaba-rocketmq-3.1.7.tar.gz# ll /usr/local./bin/sh PATH=/sbin:/bin:/usr/sbin:/usr/b... 阅2136 转11 评0 公众公开 16-01-13 21:36 |
RocketMQ延时消息的使用和延时级别的配置。RocketMQ 支持定时消息，但是不支持任意时间精度，仅支持特定的 level，例如定时 5s， 10s， 1m 等。在服务器端（rocketmq-broker端）的属性配置文件中加入以下行：发送延时消息只需要在客户端（rocketmq-client端）待发送的消息（ com.alibaba.rocketmq.common.message.Message ）中设置延时级别即可... 阅9758 转10 评0 公众公开 16-01-13 21:31 |
RocketMQ的一些特性（生产者消费者配置参数的含义）一 nameserver相对来说，nameserver的稳定性非常高。心跳超时导致broker主动关闭连接动作：一旦连接断开，broker会立即感知到，并向该消费者分组的所有消费者发出通知，分组内消费者重新分配队列继续消费 3 负载均衡集群消费模式下，一个消费者集群多台机器共同消费一个topic的多个队列，一个... 阅5968 转9 评0 公众公开 16-01-13 21:23 |
com.alibaba.rocketmq.tools.command.topic.nameserve 服务地址列表，格式ip:port;ip:port;...nameserve 服务地址列表，格式ip:port;ip:port;…com.alibaba.rocketmq.tools.command.broker.Broker 名称，表示订阅组建在该broker（这里需要注意填写的是broker 的名称，不是broker 的地址，broker名称可以在clusterList 查到。类路径 com.alibaba... 阅4333 转12 评0 公众公开 16-01-13 21:09 |
假如一个topic下有4个queue，然后当前有一个consumer group，该分组下有4个consumer，那每个consumer就被分配到该topic下的一个queue，这样就达到了平均消费topic下的queue的目的。而因为broker对于所有的consumer总是在服务的，所以，在集群消费的情况下，被订阅的topic的queue的消费位置是存储在broker上的，存储的时候按照不同的consumer gr... 阅7582 转23 评0 公众公开 16-01-13 21:07 |
消息队列RabbitMQ和ActiveMQ的生产者流量控制。每条链路有一个信元发送节点（可以是一个源端或一个交换节点）和一个接收节点（可以是一个交换节点或一个目的端系统），每个节点为每一条VC维持一个排队队列，信元接收端监视每条VC的排队队列长度，决定发送端可以发到VC上的信元数量（用信用证通知），信元发送端只能发送信用证值所允许的最大信... 阅334 转0 评0 公众公开 16-01-11 16:44 |
Erlang虽然号称N个9的稳定性，但是在实际使用中还是有很多机会看到Erlang Crash了的，其中和VM相关的Crash 十有八九是由于内存使用过量，导致系统服务分配内存导致的。Erlang的虚拟机实现和设计上都没有阻止用户往一个进程的消息队里面扔消息，当消息的生产速度过快，超过进程的处理能力，这些消息就堆积起来，占用越来愈多的内存，最终导致VM... 阅32 转0 评0 公众公开 16-01-11 16:43 |
