消息队列主要作用(消息队列有什么用)

1.软文推荐

2.软文推荐

3.软文推荐

目录： 1、MSMQ（消息系统）是什么?有什么用处? 2、rocketmq的基础概念 3、说明控制消息队列系统调用msgctl在此起什么作用 4、消息队列通信机制有哪几方面的功能 5、消息队列到底能起什么样的作用 6、Microsoft 消息队列的功能是什么 MSMQ（消息系统）是什么?有什么用处?

它的实现原理是：消息的发送者把自己想要发送的信息放入一个容器中（我们称之为Message），然后把它保存至一个系统公用空间的消息队列(Message Queue)中；本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理。

在消息传递机制中，有两个比较重要的概念。一个是消息，一个是队列。消息是由通信的双方所需要传递的信息，它可以是各式各样的媒体，如文本、声音、图象等等。消息最终的理解方式，为消息传递的双方事先商定，这样做的好处是，一是相当于对数据进行了简单的加密，二则采用自己定义的格式可以节省通信的传递量。消息可以含有发送和接收者的标识，这样只有指定的用户才能看到只传递给他的信息和返回是否操作成功的回执。消息也可以含有时间戳，以便于接收方对某些与时间相关的应用进行处理。消息还可以含有到期时间，它表明如果在指定时间内消息还未到达则作废，这主要应用与时间性关联较为紧密的应用。

消息队列是发送和接收消息的公用存储空间，它可以存在于内存中或者是物理文件中。消息可以以两种方式发送，即快递方式(express)和可恢复模式（recoverable）,它们的区别在于，快递方式为了消息的快速传递，把消息放置于内存中，而不放于物理磁盘上，以获取较高的处理能力；可恢复模式在传送过程的每一步骤中，都把消息写入物理磁盘中，以得到较好的故障恢复能力。消息队列可以放置在发送方、接收方所在的机器上，也可以单独放置在另外一台机器上。正是由于消息队列在放置方式上的灵活性，形成了消息传送机制的可靠性。当保存消息队列的机器发生故障而重新启动以后，以可恢复模式发送的消息可以恢复到故障发生之前的状态，而以快递方式发送的消息则丢失了。另一方面，采用消息传递机制，发送方必要再担心接收方是否启动、是否发生故障等等非必要因素，只要消息成功发送出去，就可以认为处理完成，而实际上对方可能甚至未曾开机，或者实际完成交易时可能已经是第二天了。

采用MSMQ带来的好处是：由于是异步通信，无论是发送方还是接收方都不用等待对方返回成功消息，就可以执行余下的代码，因而大大地提高了事物处理的能力;当信息传送过程中，信息发送机制具有一定功能的故障恢复能力；MSMQ的消息传递机制使得消息通信的双方具有不同的物理平台成为可能。

在微软的.net平台上利用其提供的MSMQ功能，可以轻松创建或者删除消息队列、发送或者接收消息、甚至于对消息队列进行管理。

在.NET产品中，提供了一个MSMQ类库System.Messaging.dll。它提供了两个类分别对消息对象和消息队列对象进行操作。在能够使用MSMQ功能之前，你必须确定你的机器上安装了MSMQ消息队列组件，并确保服务正在运行中。在使用ASP.NET编程时，应在头部使用：

%@ Assembly Name=System.Messaging%rocketmq的基础概念

先来说一下基本概念。

消息队列本身就是一个存放消息的容器，如果非要从数据结构的角度来理解，那就是一个有序集合。这个集合中的每个对象都是消息，先进先出。

那么什么是消息呢？

消息就像一个指令，一个命令。举个例子，你妈喊你回家吃饭了，这就是一个消息，但是至于你怎么吃，这是你的事情，我觉得你妈或者其他人并不会感兴趣，因为怎么吃，是你自己决定的。

那么队列呢？可以理解成，你妈妈喊你回家吃饭，然后叮嘱让你把饭吃干净，然后再洗碗。这里面就存在着一个队列，先吃饭，让你吃干净点，再洗碗。这里面就好几个消息。这就是一个队列。

为什么叫消峰，出现峰峰值，把这个峰峰值给铺平，就叫消峰。

很多时候，服务器的压力并不大，但是某个时候，服务器的压力陡增怎么办？

比如像淘宝，只有双11,618或者搞某些活动的时候。用户大量下单，请求的流量才会暴增。

那么面对这种情况，解决方案确实很多，加服务器，用nginx去负载均衡，这是一种可行的方法，不过大多数的时候服务器都是闲置的，就会是资源浪费了。避免资源浪费的话，只能前提部署，用完撤走，那这样子是不是很麻烦？

另外考虑一个场景，如果服务器只支持1000个用户同时下单，假设每处理一个客户的订单需要一秒，那后面每多一个客户，后面的客户就需要等待（n - 1000）秒。等的人多了，基于服务器的线程模型(定长线程池)，一下子就撑不住了(队列的长度也不是无限的)，只能强迫性的不让后面的客户去等，直接告诉他奔溃了？这体验也很不好吧?

那么是不是可以考虑采取一种措施，告诉客户下单的操作成功，但是成功还是失败后面再告诉客户？这样子服务器的压力也不会那么大，因为没有那么多内容在队列中堆积。告诉客户操作成功只需要0.1秒，而告诉客户下单成功(需要1秒)。同样资源的情况下，意味着同样的时间内，吞吐提高了10倍。假如把陡增的请求，堆积的任务队列形容成山峰，那么消息队列的作用，就是增加服务的吞吐，把堆积的任务队列尽快的消化。

这个角度其实是空间换时间，用空间去存储消息，多浪费点内存，但是让服务的性能保持平稳。

举个例子，如果一个客户下单，有一个A服务是专门接收订单的。B服务是专门消费订单的。

A服务B服务直接的通信，可以通过http请求，但是这样做意味着强耦合。B服务需要强制性的去定义一个请求体，用于处理来自A服务的请求。当B服务定义的结构体发生变更的时候，A服务就会调用失败。

消息队列则实质上并不会去考虑业务结构体，消息的本身是一个通用的结构，发起方与消费方，都需要遵守这个协议，需要去考虑的只是这个结构体的内容。

如果想要去主动的去处理某些业务，只需要遵守这个结构体，发起请求即可。这样子所有的系统，都可以接入，同时不存在耦合。

消息队列提供了一个消息转换的过程，让各个不同业务服务之间进行解耦。

可以简单的理解成，不同的业务有着不同的队列，他们之间的消费互不干扰。

因为有一些mq我是没用过的，所以这块的话，是从网上找的资料。

从上面的图来看。

rocketmq是具备一定的优势的，针对大并发，且延时性相对高一些的应用场景。

此外rocketmq的功能相对完善，拓展性强，另外前身也是阿里开发的，只是后面送给了阿帕奇社区。

至于为什么那么强大，估计得后面才知道为什么。

概念：其实说白了就是注册中心(AP)，AP使得rocketmq的设计比较简单也轻量，因为减少了nameServer之间的通信。

作用：路由功能。

nameServer中存储了路由信息(topic(可以粗略理解成消息的类型)与对应的broker实际地址的关系)

producer可以通过topic找到需要的Broker的实际地址，决定把消息发哪里去

consumer可以通过topic找到需要的broker的实际地址，决定从哪里获取消息

概念：说白了就是存储消息队列的容器。

作用: 消息的持久化

概念：生产者

作用：用于生产消息，将消息发送到存储容器

概念：消费者

作用：消费消息，从消息的存储容器中获取消息，并且进行具体的业务实现。

其实特性有很多，不过我了解的还不是很深入，暂时就只举例这些。

在某些特定业务场景，可能对消息的顺序有要求。比如日志，需要一条一条打印，这就需要顺序。

Topic的队列是我们实现有序性的关键，一个topic中，任意队列内部的所有消息均可以认为是有序的，均满足先进先出的有序条件。

针对有序性的需求，围绕队列展开，通常有两种解决方案。

全局有序是指，业务对有序性对要求是一个topic内所有消息全部有序。为了达到全局有序的要求，可以将topic的队列数设置为1，即是说所有消息，均投递至同一个队列中，自然也就达到全局有序的效果。

分组有序是指，业务对一个topic内的所有消息按照某种条件水平拆分为不同的分组后，组内有序。已知topic的单个队列天然有序，那么只需要将水平拆分后的一组消息，全部发送至同一个topic的队列，即可实现分组有序。

那么为什么只有这俩种有序方式呢？倘若一个topic有多个队列，且消息类型完全是一样的(即同种业务)，对于同个队列来说必然是先进先出，但是如果俩个容量不同的队列，前面发出的消息恰好加在了任务比较多堆积的队列，后面发出的消息恰好加在了任务堆积比较少的队列，这个时候就不能保证有序了。

消息在生产或者消费的过程中可能会出现异常，rocketmq支持事务，但是这个事务的处理过程是由开发人员自己去实现的

消息允许被延时消费

RocketMQ支持消息的高可靠，影响消息可靠性的几种情况：

Broker正常关闭

Broker异常Crash

OS Crash

机器掉电，但是能立即恢复供电情况

机器无法开机（可能是cpu、主板、内存等关键设备损坏）

磁盘设备损坏

1)、2)、3)、4) 四种情况都属于硬件资源可立即恢复情况，RocketMQ在这四种情况下能保证消息不丢，或者丢失少量数据（依赖刷盘方式是同步还是异步）。

5)、6)属于单点故障，且无法恢复，一旦发生，在此单点上的消息全部丢失。RocketMQ在这两种情况下，通过异步复制，可保证99%的消息不丢，但是仍然会有极少量的消息可能丢失。通过同步双写技术可以完全避免单点，同步双写势必会影响性能，适合对消息可靠性要求极高的场合，例如与Money相关的应用。注：RocketMQ从3.0版本开始支持同步双写。

一个topic分布在多个broker上，一个broker可以配置多个topic，它们是多对多的关系。一个queue对应一个Broker集群

如果某个topic消息量很大，应该给它多配置几个队列，并且尽量多分布在不同broker上，减轻某个broker的压力。

topic消息量都比较均匀的情况下，如果某个broker上的队列越多，则该broker压力越大。

生产者可以考虑选择合适的队列(根据队列的状态，比如是否堆积了过多的任务)，去存储消息

netty(nio的框架，轻量高效，可能不懂这个，源码没法看)

java基础

说明控制消息队列系统调用msgctl在此起什么作用

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

消息队列通信机制有哪几方面的功能

“消息队列”是 Microsoft 的消息处理技术，它在任何安装了 Microsoft Windows 的计算机组合中，为任何应用程序提供消息处理和消息队列功能，无论这些计算机是否在同一个网络上或者是否同时联机。

系统根据消息队列在message map 中顺序查找对应message处理函数,进行响应消息

消息队列到底能起什么样的作用

因为短信不能一次性群发，所以就有短信消息队列功能，把队列里面的短信 每各几秒或者是在多少时间内处理完。

Microsoft 消息队列的功能是什么

总的来说消息队列提供了一种异步消息传递机制。在windows中，一个窗口的执行分为下面几个步骤：1、窗口类声明 2、窗口类注册 3、创建窗口 4、显示窗口 5、消息循环。一般情况下，当一个窗口发生一个事件时，系统会将该事件以消息的形式送往消息队列中，消息中至少包含了：消息类型、窗口句柄、附加参数等。当窗口处于消息循环中时，系统就使用到了消息队列，它会调用GetMessage()函数从消息队列中拿出窗口事件发生时的消息，并把它交给你的程度中声明的窗口过程即回调函数去处理，从而完成一次事件的响应。

希望对你有所帮助。