一、安装Rabbit MQ Rabbit MQ 是建立在强大的Erlang OTP平台上,因此安装Rabbit MQ的前提是安装Erlang。通过下面两个连接下载安装3.2.3 版本: 原因是,安装 Rabbit MQ的过程中没有使用默认的安装路径。重新安装并使用默认的安装路径就没有问题了。如果使用 ...
分类:
编程语言 时间:
2017-02-02 23:52:00
阅读次数:
1030
RabbitMQ使用 参考链接地址:http://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html 建立两个控制台程序,一个用于发送,一个用于接收,服务端用的是别人搭好的环境,暂时不管 通过NuGet获取需要引用的库输入RabbitMQ搜索即可, ...
分类:
其他好文 时间:
2017-01-28 18:52:19
阅读次数:
271
niubi-job的框架设计是非常简单实用的一套设计,去掉了很多其它调度框架中,锦上添花但并非必须的组件,例如MQ消息通讯组件(kafka等)。它的框架设计核心思想是,让每一个jar包可以相对之间独立的运行,并且由zk辅助进行集群中任务的调度。 接下来,咱们就一步一步的来看下niubi-job整个的 ...
分类:
其他好文 时间:
2017-01-27 07:05:12
阅读次数:
306
不管是官方还是能搜到的文章,使用MQ的基本思路都是这样: 那么问题来了: 这个"Hello World"怎么传进去?如何对外提供服务? 然后会发现有些客户端SDK是这么处理的: 去公开一个接口调用SendMsg吧。 看起来似乎解决了这个问题,但是实际测试下会吓一跳:后者的QPS仅为前者的40%左右, ...
分类:
其他好文 时间:
2017-01-20 16:09:08
阅读次数:
255
最近几周粗略看了 skynet 代码的 C 部分。遇到很多知识点以前只是知道,但并不十分了解,所以这是一个学习的过程。 从 main 函数开始,闷头一阵看下来,着实蛋疼。 当看了 skynet_mq.c 和 skynet_module.c 之后才终于有了头绪。 C 代码通篇下来并没有什么特别的难点。 ...
分类:
Web程序 时间:
2017-01-19 03:28:57
阅读次数:
515
启动服务器56:ssh -l root -p 49622 10.15.0.56 Are you sure you want to continue connecting (yes/no)? yes 密码: cd apache-activemq-5.14.3 cd bin/ 启动mq:./active ...
分类:
其他好文 时间:
2017-01-17 12:42:14
阅读次数:
153
RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链 ...
分类:
编程语言 时间:
2017-01-14 08:41:50
阅读次数:
239
ELKStack-使用消息队列扩展 官方文档:https://www.elastic.co/guide/en/logstash/5.x/deploying-and-scaling.html 流程图 流程:数据源 --> logstash(input收集、output消息队列) --> MQ --> ...
分类:
其他好文 时间:
2017-01-07 13:13:52
阅读次数:
232
通道(channel)通道其实是队列管理器之间的一种点对点的通信连接,消息在通道中只能单向流动。如果需要双向交流,可以建立一对通道,一个发送端和一个接受端口。从队列管理器的角度出发通道安消息的流向可以分为输入通道和输出通道。通过配置对于放入本地传输队列中的消息,队..
分类:
Web程序 时间:
2017-01-05 12:18:43
阅读次数:
744
在MQ中其实队列的概念基本上和我们上学时的数据结构中的概念是一样的,这个队列其实就是一个容器,用来存放消息。其中队列可以分成如下所示:本地队列:其中只有本地队列才是真正意义上的队列实体。其中本地队列可以分为:初始化队列(初始化队列用作消息的触发功能)、目标队..
分类:
Web程序 时间:
2017-01-05 00:00:43
阅读次数:
464