云消息队列

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

在阿里云生态日，阿里巴巴中间件产品专家不铭分享了《Aliware-MQ消息队列》。他从功能特性、技术架构、最佳实践、案例分析四个方面进行了分享。在分享中，他主要介绍了Aliware-MQ的线性扩展技术、存储模型、负载均衡、数据流、刷盘策略、高可靠/高可用方案进行了介绍，并通过案例进行了具体实践分享。

近期，消息队列（MQ）推出顺序消息消息、MQTT移动物联套件、Kafka企业级消息服务。下述内容将解析消息队列（MQ）顺序消息、车联网、Kafka企业级消息服务的应用场景。

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

一般来说，消息队列都会保证queue当中的消息的顺序。然而如果有多个consumer同时消费同一个queue，那么这时就不能保证的消息的顺序性。 有时候，消息的顺序是非常重要的，为了能顺序的消费消息，我们只能启动一个consumer来消费这个queue。

简介 近年来随着 Web 前端的快速发展，浏览器新特性层出不穷，越来越多的应用可以在浏览器端或通过浏览器渲染引擎实现，Web 应用的即时通信方式 WebSocket 得到了广泛的应用。 WebSocket 是一种在单个 TCP 连接上进行全双工通讯的协议。

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

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

springboot使用rabbitmq消息队列

针对消息队列的数据积压问题，我们主要做了三个方面的优化处理，取消同步锁、ActiveMQ参数优化、本地双队列优化，通过这三个方面的优化基本解决了队列数据积压的问题。

springboot 整合消息队列RabbitMQ

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

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

消息是指在两个独立的系统间传递的数据，这两个系统可以是两台计算机，也可以是两个进程。 消息可以非常简单，可以是简单的字符串，也可以是保存了数据持久化的各种类型的文档集合。 队列是在消息的传输过程中的通道，是保存消息的容器，根据不同的情形，可以有先进先出，优先级队列等区别 。

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

一、课程介绍 如果您从工作中之听过但未有接触过消息对队列(MQ)，如果你接触过一点关于MQ的知识，如果没有这么的多如果的话......，那么阿笨将通过本次《C#消息队列零基础从入门到实战演练》分享课让您对消息队列有一个实质性的了解和认识，达到实际的灵活贯通和运用。

本篇笔记旨在使用Redis的List(列表)命令实现消息队列，生产者使用lPush命令发布消息，消费者使用rpoplpush命令获取消息，同时将消息放入监听队列，如果处理超时，监听者将把消息弹回消息队列

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

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

本文讲的是7年磨一剑 阿里云消息队列正式商用【IT168 云计算】2月29日，阿里云宣布中间件产品消息队列(Message Queue，下文简称MQ)正式商用。MQ可轻松解决企业应用之间的通信问题，满足计算场景中所有的异步解耦需求。

Linux进程通信，软中断+消息队列，实现了简单的聊天功能。

消息队列设计精要总结之基础篇 消息队列概述 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。

  一、消息队列概述 消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。

1、安装运行环境 yum install erlang 2、安装RabbitMQ wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.

转载：[http://www.jasongj.com/2015/01/02/Kafka%E6%B7%B1%E5%BA%A6%E8%A7%A3%E6%9E%90/](http://www.jasongj.com/2015/01/02/Kafka%E6%B7%B1%E5%BA%A6%E8%A7%A3%E6%9E%90/) 这篇文章在初次接触kafka时，便拜读过，确实写的很好，另外其他系列文章也同样有可取之处。

车主无忧开源的Kafka多副本存储，存储压力大，处理冷数据读的时候处理速度明显下降。上云后消息集群平稳运行，提升诊断效率、指导优化系统。