云消息队列

Redis Stream Redis最新的大版本5.0已经RC1了，其中最重要的Feature莫过于Redis Stream了，关于Redis Stream的基本使用介绍和设计理念可以看我之前的一篇文章（Redis Stream简介）。

前言 只有光头才能变强。 文本已收录至我的GitHub仓库，欢迎Star：https://github.com/ZhongFuCheng3y/3y 公司用到的很多技术，自己之前都没学过(尬)，于是只能慢慢补了。

前言 最近在做一款秒杀的案例，涉及到了同步锁、数据库锁、分布式锁、进程内队列以及分布式消息队列，这里对SpringBoot集成Kafka实现消息队列做一个简单的记录。 Kafka简介 Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。

这里我使用Redis的发布、订阅功能实现简单的消息队列，基本的命令有publish、subscribe等。 在Jedis中，有对应的java方法，但是只能发布字符串消息。为了传输对象，需要将对象进行序列化，并封装成字符串进行处理。

下面来说说如何用不用消息队列来进行进程间的通信，消息队列与命名管道有很多相似之处。有关命名管道的更多内容可以参阅我的另一篇文章：Linux进程间通信——使用命名管道   一、什么是消息队列 消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法。

在全面兼容Apache Kafka生态的基础上，消息队列Kafka彻底解决Apache Kafka稳定性不足的长期痛点，并且支持消息无缝迁移到云上。

RPC（Remote Procedure Call）—远程过程调用 ，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。

38道Java面试题解析（MyBatis+消息队列+Redis）

在消息队列中，当消费者去消费消息的时候，无论是通过 pull 的方式还是 push 的方式，都可能会出现大批量的消息突刺。如果此时要处理所有消息，很可能会导致系统负载过高，影响稳定性。但其实可能后面几秒之内都没有消息投递，若直接把多余的消息丢掉则没有充分利用系统处理消息的能力。

今天的首篇文章，讲述了：网易云音乐从13年4月上线以来，业务和用户突飞猛进。后台技术也从传统的 Tomcat 集群到分布式微服务快速演进和迭代，在业务的不断催生下，诞生了云音乐的 RPC，API 网关和链路跟踪等多种服务，消息队列也从 RabbitMQ 集群迁移到 Kafka集群。

目录 RabbitMQ简介 RabitMQ 概念模型 Exchange 类型 代码实战 RabbitMQ简介 AMQP:Advanced Message Queue，高级消息队列协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。

springboot 整合消息队列RabbitMQ

https://www.ibm.com/developerworks/cn/linux/l-ipc/part3/ 继续坚持，或许不能深刻理解，但至少要保证有印象。 ~~~~~~~~~~~~~~ 消息队列（也叫做报文队列）能够克服早期unix通信机制的一些缺点。

Redis的消息队列使用简单，没有什么配置，比ActiveMQ要轻量级太多，当然功能也比较简单，如果只需要简单的订阅以及发布，可以考虑使用它。 **订阅操作** 命令为:subscribe [channel] [channel] ..，如【代码1】所示，即成功订阅频道[redis.blog]。 **发布操作** 命令为publish [channel] [message]，

7月25日，阿里云宣布正式推出消息队列Kafka，全面融合开源生态。在兼容Apache生态的基础上，阿里云消息队列Kafka彻底解决了开源产品稳定性不足的痛点，可用性达99.9%，数据可靠性99.999999%，并且支持消息无缝迁移到云上。

在上一篇帖子剖析nsq消息队列(一) 简介及去中心化实现原理中，我介绍了nsq的两种使用方式，一种是直接连接，还有一种是通过nslookup来实现去中心化的方式使用，并大概说了一下实现原理，没有什么难理解的东西，这篇帖子我把nsq实现去中心化的源码和其中的业物逻辑展示给大家看一下。

7月25日，阿里云宣布正式推出消息队列Kafka，全面融合开源生态。在兼容Apache生态的基础上，阿里云消息队列Kafka彻底解决了开源产品稳定性不足的痛点，可用性达99.9%，数据可靠性99.999999%，并且支持消息无缝迁移到云上。

Kafka是什么，JMS是什么，常见的类JMS消息服务器，为什么需要消息队列（来自学习笔记） 1、Kafka是什么  Apache Kafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。

前言：前面讨论了信号、管道的进程间通信方式，接下来将讨论消息队列。 　　一、系统V IPC 　　三种系统V IPC：消息队列、信号量以及共享内存（共享存储器）之间有很多相似之处。 　　每个内核中的 I P C结构（消息队列、信号量或共享存储段）都用一个非负整数的标识符( i d e n t i f i e r )加以引用。

部署和启动ActiveMQ 去官网下载：http://activemq.apache.org/ 我下载的是apache-activemq-5.12.0-bin.tar.gz， 解压到本地目录，进入到bin路径下， 运行activemq启动ActiveMQ。

消息中间件 消息中间件即Message-oriented middleware(MOM)，消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 通过提供消息传递和消息排队模型，消息中间件可以在分布式环境下扩展进程间的通信。

前段时间实现了一个基于RabbitMQ的消息总线，实现的过程中自己也在不断得思考、总结以及修正。需要考虑各个维度：效率、性能、网络、吞吐量、甚至需要自己去设想API可能的使用场景、模式。不过能有一件事情，自己愿意去做，在走路、吃饭、坐公交的时候都在思考如何去改进它，然后在实践的过程中，促使去思考并挖掘自己知识面的空白，也是一件让人开心的事情。

RPC RPC（Remote Procedure Call）远程过程调用，主要解决远程通信间的问题，不需要了解底层网络的通信机制。 RPC框架 知名度较高的有Thrift(FB的)、dubbo(阿里的)。

目前阿里云官方对于微消息队列 MQTT提供了很多语言的参考示例，但是在实际的使用中发现很多用户在使用Android Sample的时候总是会遇到问题，无法正常调试使用。本文主要介绍Android Sample的使用。

最近在看消息队列框架 ，alibaba的RocketMQ单机支持1万以上的持久化队列，支持诸多特性， 目前RocketMQ在阿里集团被广泛应用在订单，交易，充值，流计算，消息推送，日志流式处理，binglog分发等场景 比kafka还是有过之无不及，其实kafka文档很丰富 但RocketMQ网上的...

　　前言：最近在学进程间通信，所以做了一个小项目练习一下。主要用消息队列和socket(UDP)实现这个系统，并数据库存储数据，对C语言操作不熟悉的可以参照我的这篇博客：https://www.cnblogs.com/liudw-0215/p/9593414.html，所有代码提交我的Github上，地址：https://github.com/ldw0215/Chat-System.git，可以自行下载，然后make一下就可以了。

写在前面,mq简称消息队列,本文介绍的是activemq.那mq主要用在什么场景，他的作用又是什么呢? 介绍:mq称为消息中间件,语言表达不如看图. image.png image.png 顾名思义,mq主要还是为了提高服务器响应速度，提高客户体验.举个例子大家就应该明白了。

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。 消息被处理的过程相当于流程A被处理。我们这里以一个实际的模型来讨论下，比如用户下单成功时给用户发短信，如果没有这个消息队列，我们会选择同步调用发短信的接口， 并等待短息发送成功，这时候假设短信接口实现出现问题了，或者短信调用端超时了，又或者短信发送达到上限了，我们是选择重试几次还是放弃，还是选择把这个放到数据库 过一段时间再看看呢，不管怎样，实现都很复杂。

Redis的消息队列使用简单，没有什么配置，比ActiveMQ要轻量级太多，当然功能也比较简单，如果只需要简单的订阅以及发布，可以考虑使用它。 订阅操作 命令为:subscribe [channel] [channel] ..，如【代码1】所示，即成功订阅频道[redis.blog]。 发布操作 命令为publish [channel] [message]，如【代码2

原文:[.NET领域驱动设计实战系列]专题八：DDD案例：网上书店分布式消息队列和分布式缓存的实现 一、引言  　　在上一专题中，商家发货和用户确认收货功能引入了消息队列来实现的，引入消息队列的好处可以保证消息的顺序处理，并且具有良好的可扩展性。

aurora 是一个基于 Web 的 Beanstalk 消息队列服务器管理工具，单文件无需依赖其他组件，支持管理本地和远程多个队列服务器