Java消息队列总结只需一篇解决ActiveMQ、RabbitMQ、ZeroMQ、Kafka
一、消息队列概述 消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ &nbs...
ZeroMQ(java)中监控Socket
基本上ZeroMQ（java）中基本的代码都算是过了一遍了吧，不过觉得它在日志这一块貌似基本没有做什么工作，也就是我们通过日志来知道ZeroMQ都发生了什么事情。。 而且由于ZeroMQ中将连接的建立和重连接都进行了隔离，用户不需要做什么事情来维护连接，当然这样做的好处是使程序员的编码工作变少了，但...
ZeroMQ(java)中的数据流SessionBase与SocketBase
前面的文章中已经比较的清楚了ZeroMQ（java）中如何在底层处理IO， 通过StreamEngine对象来维护SelectableChannel对象以及IO的事件回调，然后通过Poller对象来维护Selector对象，然后用IOObject对象来具体的管理SelectableChannel对象...
ZeroMQ(java)中组件间数据传输（Pipe的实现）
在ZeroMQ（java）中，整个IO的处理流程都是分层来进行的，当然处于最下端的肯定是前面介绍过的poller以及StreamEngin了。。。。涉及到上层的话就还有session，以及socket，先用一张图来大概的描述一下整个层次关系吧。。 整个分层的结构大概就是这样吧，其中poller与St...
ZeroMQ（java）中对IO的封装（StreamEngine）
哎，各种各样杂七杂八的事情。。。好久没有看代码了，其实要搞明白一个与IO相关的框架，最好的办法就是把它的I/0的读写两个过程搞清楚。。。例如在netty中，如果能将eventLoop的运行原理搞清楚，然后摸清楚整个I/O读写两个过程，那么也就差不太多了。。。。 这次来看看ZeroMQ（java）中如...
ZeroMQ(java)之I/O线程的实现与组件间的通信
算是开始读ZeroMQ（java）的代码实现了吧，现在有了一个大体的了解，看起来实现是比较的干净的，抽象什么的不算复杂。。。 这里先来看看它的I/O线程的实现吧，顺带看看是如何实现组件的通信的。。。。 首先要搞清楚I/O线程的实现，就先要弄懂一个类型，Poller（zmq.Poller.java），...
ZeroMQ(java)之负载均衡
我们在实际的应用中最常遇到的场景如下： A向B发送请求，B向A返回结果。。。。 但是这种场景就会很容易变成这个样子： 很多A向B发送请求，所以B要不断的处理这些请求，所以就会很容易想到对B进行扩展，由多个B来处理这些请求，那么这里就出现了另外一个问题： B对请求处理的速度可能不同，那么B之间他们的负...
ZeroMQ(java)之Router与Dealer运行原理
在开始这部分的内容之前,先来看看ZeroMQ中HWM概念---High-Water Marks 当系统的数据量很大,而且发送频率很高的情况下,内存就很重要了,如果处理不好会出现很多问题,例如如下场景: A很快速的向B发送数据,但是B处理起来却很慢,这样子的话,数据就可能会在A的发送缓冲区,或者B的接...
ZeroMQ(java)之Router/Dealer模式
本教程转自:http://blog.csdn.net/kobejayandy/article/details/20163527 在开始之前先把guid里面提到的几个ZeroMQ的特性列一下吧： （1）ZeroMQ有自己的I/O线程来异步的处理I/O，而且后台采用了无锁的数据结构 （2）在...
ZeroMQ之Push与Pull (Java)
本系列文章均转自:http://blog.csdn.net/kobejayandy/article/details/20163431 在ZeroMQ中并没有绝对的服务端与客户端之分，所有的数据接收与发送都是以连接为单位的，只区分ZeroMQ定义的类型，例如Response与Request，Publi...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
