云消息队列

基于Redis实现消息队列

消息队列RocketMQ

一、前言 需求：电商秒杀场景中，如果用户下单10分钟未支付，需要进行库存归还 本篇是用PHP+Laravel+RabbitMQ来实现异步延迟消息队列

【Android 异步操作】Handler 机制 ( MessageQueue 消息队列的阻塞机制 | Java 层机制 | native 层阻塞机制 | native 层解除阻塞机制 )（二）

【Android 异步操作】手写 Handler ( Message 消息 | ThreadLocal 线程本地变量 | Looper 中的消息队列 MessageQueue )

消息队列比作是一个存放消息的容器，当我们需要使用消息的时候可以取出消息供自己使用。消息队列是分布式系统中重要的组件，使用消息队列主要是为了通过异步处理提高系统性能和削峰、降低系统耦合性。下面主要介绍RabbitMQ、RocketMQ和Kafka三款消息中间件的选型。

在高并发业务场景下，消息队列在流量削峰、解耦上有不可替代的作用。当前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、Pulsar 等。 消息队列这么多，到底该选择哪款消息队列呢？ 选择消息队列的基本标准 虽然这些消息队列在功能和特性方面各有优劣，但我们在选择的时候要有一个基本标准。

上两篇帖子主要说了一下nsq的拓扑结构，如何进行故障处理和横向扩展,保证了客户端和服务端的长连接，连接保持了，就要传输数据了，nsq如何保证消息被订阅者消费，如何保证消息不丢失，就是今天要阐述的内容。

在分布式系统架构中，尤其是金融级业务应用的解决方案设计中，消息队列提供 “事务型消息” 特性是必不可少的，“数据一致性” 是金融级分布式架构的基本要求。

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

初次使用AMQP的过程中，总是容易被AMQP支持的消息模型绕晕，这里结合官方的教程，对AMQP的消息模型做一个简要总结，供参考。目前官方给出了六种消息发送/接收模型，这里主要介绍前五种消息模型。

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

原文:【c#】队列（Queue）和MSMQ（消息队列）的基础使用       首先我们知道队列是先进先出的机制，所以在处理并发是个不错的选择。然后就写两个队列的简单应用。 Queue 命名空间     命名空间：System.Collections，不在这里做过多的理论解释，这个东西非常的好理解。

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

springboot 整合消息队列RabbitMQ

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

消息队列设计精要总结之高级特性篇 队列高级特性设计 上面都是些消息队列基本功能的实现，下面来看一些关于消息队列特性相关的内容，不管可靠投递/消息丢失与重复以及事务乃至于性能，不是每个消息队列都会照顾到，所以要依照业务的需求，来仔细衡量各种特性实现的成本，利弊，最终做出最为合理的设计。

引言 复习要点 本文大概围绕如下几点进行阐述: 为什么使用消息队列？ 使用消息队列有什么缺点? 消息队列如何选型? 如何保证消息队列是高可用的？ 如何保证消息不被重复消费? 如何保证消费的可靠性传输? 如何保证消息的顺序性？ 我们围绕以上七点进行阐述。

前言         本人觉得码农的技术提升应该是从how to do到why do，而项目或产品都是从why do到how to do，按题来，所以呢下面先从大的方面介绍一下消息队列。         消息队列是分布式高并发面目中必不可少的一部分，随着互联网、云计算、大数据的使用，消息队列的应...

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

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

在开发中应用过ActiveMQ，kafka等mq，不过对消息队列背后的实现原理关注不多，其实了解消息队列背后的实现特别重要，比如对一致性等实现的关注，可以帮助我们在开发中避免踩坑，规避问题的出现。这篇文章简单探讨下当设计和实现一个消息队列时，我们需要关心哪些地方。

通常情况下，为了提高系统开发的灵活性和可维护度，我们会采用消息队列队系统进行解耦。下面是一个采用spring redis实现的消息队列实例，但此实例会由于网络延迟和阻塞等情况导致消息处理的延时，因而不能确保消息处理的顺序，所以使用时需要注意。

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

G MEMCACHEQ AS MESSAGE QUEUE PHP,消息队列,MEMCACHEQ 使用消息队列（MESSAGE QUEUE）可以把某些耗时的工作推后，然后在后台慢慢地去执行，这样就不会让你的用户等待太久。

RocketMQ配置复杂？试试这款可视化工具，轻松搞定配置难题，点击体验：https://how-to-config-rocketmq.demoworld.tech/

【8月更文挑战第15天】RocketMQ体验测评