Rabbitmq集群的搭建

经过前面Kafka实战系列的学习，我们通过学习《Kafka实战－入门》了解Kafka的应用场景和基本原理，《 Kafka实战－Kafka Cluster 》一文给大家分享了Kafka集群的搭建部...

taiji 是一个 kafka 的 consumer 实现，可以支持从 kafka 拉取消息，并使用 http 协议发送至多个下游，特别适合 php 类无常驻进程的架构体系。

前面给大家介绍了整个Kafka项目的开发流程，今天给大家分享Kafka如何获取数据源，即Kafka生产数据。

之前写过两篇文章，分别是 《前端抢后端饭碗 — Node.js + Socket.io 制作简易聊天室》 和 《koa + socket.io 制作简易聊天室》 ，实质上都是利用了浏览器的web...

Spring对JMS提供了很好的支持，可以通过JmsTemplate来方便地实现消息服务。本例通过 activeMQ服务器模拟了消息的发送与接收。需要注意的是，activeMQ的运行依赖jdk的...

Kafka是一个消息系统，原本开发自LinkedIn，用作LinkedIn的活动流（activity stream）和运营数据处理管道（pipeline）的基础。现在它已为多家不同类型的公司 作...

在《Kafka实战－简单示例》一文中给大家介绍来Kafka的简单示例，演示了如何编写Kafka的代码去生产数据和消费数据，今天给大家介绍如何去整 合一个完整的项目，本篇博客我打算为大家介绍Flu...

Kafka的consumer是以pull的形式获取消息数据的。不同于队列和发布-订阅模式，kafka采用了consumer group的模式。通常的，一般采用一个consumer中的一个grou...

Apache Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，之后成为Apache项目的一部分。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交...

在这篇教程中，我们将给它添加一个功能 - 我们将使它能够只订阅消息的一个子集。比如，我们将能够只把严重的error消息给导到log文件(保存到磁盘)中，而仍然能够在终端打印所有的log消息。

Apache ActiveMQ Artemis 提供了一个非堵塞架构，实现了超高性能的 Java 对象消息服务器。其核心只依赖一个 netty.jar 文件。该项目的目的是为你的 Java 应用...

今天让我们来谈谈身份高贵，举止优雅的消息中间件，主要还是浅谈，消息中间件这块水太深。大体上我们结合互联网业务做一些探讨，从互联网主要关心的消息安全性，服务器的稳定性容错性以及吞吐量三方面来讲。 ...

VerneMQ 是一个高性能、分布式的 MQTT 消息代理。可在流行的硬件上轻松实现水平和垂直扩展，用于支持高并发的消息发布和订阅服务，同时维持低延迟和容错特性。

[emqttd]是采用Erlang语言开发，全面支持MQTT V3.1.1协议，支持集群和大规模连接的开源MQTT消息服务器。 [emqttd]致力于发布一个基于Erlang/OTP语言平台，企...

经过一个多月的时间观察，业务上在集成Kafka后，各方面还算稳定，这里打算抽时间给大家分享一下Kafka在实际场景中的一些使用心得。本篇博客打算先给大家入个门，让大家对Kafka有个初步的了解，...

RabbitMQ提供了完善的管理和监控工具，分management plugin 和 rabbitmqctl 两种类型的工具。

“分布式系统是你甚至不知道的一台计算机上的故障可以使您自己的计算机不可用。”-Leslie Lamport 随着云计算的普及和可用性，分布式系统架构已很大程度上取代了更多的整体构建。当然...

它就那么简简单单地用顺序写的普通文件，借力于Linux内核的Page Cache，不(显式)用内存，胜用内存，完全没有别家那样要同时维护内存中数据、持久化数据的烦恼——只要内存足够，生产者与消费...

消息队列系统是大型分布式系统中常见的组成部分之一，目前市面上也已经出现了大量非常优秀的消息队列或者具有消息队列特征的数据流系统，它们各自有各自的特点，却也同样会有自己的不足，在某些特定的应用场景...