import{_ as o}from"./RocketMQ总览-CkeAZEv3.js";import{_ as a,c as p,a as t,b as l,d as i,f as n,r as c,o as s,e as m}from"./app-DphQsCr3.js";const d="/assets/%E6%B6%88%E6%81%AF1-q1xKDG9K.png",u="/assets/%E6%B6%88%E6%81%AF2-Dbf8lx90.png",k="/assets/%E6%B6%88%E6%81%AF3-BrPPHZ4s.png",h={},g={class:"table-of-contents"};function _(f,e){const r=c("router-link");return s(),p("div",null,[e[1]||(e[1]=t("h1",{id:"rocketmq-基础",tabindex:"-1"},[t("a",{class:"header-anchor",href:"#rocketmq-基础"},[t("span",null,"RocketMQ - 基础")])],-1)),t("nav",g,[t("ul",null,[t("li",null,[l(r,{to:"#各个组件"},{default:i(()=>e[0]||(e[0]=[m("各个组件")])),_:1})])])]),e[2]||(e[2]=n('<blockquote><p>学习任何东西需要先有一个整体的认识，然后再深入学习，钻研细节，最后再抓住核心脉络，总结整理消化在自己脑海中形成体系。</p></blockquote><h1 id="什么是消息队列" tabindex="-1"><a class="header-anchor" href="#什么是消息队列"><span>什么是消息队列</span></a></h1><p>从消息的传递入手，这就是我们开发经常会遇到的：</p><p><img src="'+d+'" alt=""></p><p>随着消息越来越大，避免消息的丢失，引入了中转站的概念，和微信的未读消息一致会有一种方式提醒消息的消费者：</p><p><img src="'+u+'" alt=""></p><p>但是，一个中转站也可能存不下这么多消息，因此想到了扩展中转站：</p><p><img src="'+k+'" alt=""></p><p>但是随着中转站变多，发送者和消费者如何知道消息应该发到哪个中转站或者从哪个中转站读取消息呢？</p><p>引出今天的主人公：RocketMQ</p><h1 id="rocketmq总览" tabindex="-1"><a class="header-anchor" href="#rocketmq总览"><span>RocketMQ总览</span></a></h1><p>首先看一下RocketMQ的相关组件和角色：</p><p><img src="'+o+'" alt=""></p><ul><li>producer就类似上面的开发小A和Leader王</li><li>producer group-A组进一步可以理解成开发同事的集合</li><li>namesrvl、2类似于看板。</li><li>BrokerA、B类似于中转站1、2</li><li>Broker Cluster就是中转站们</li><li>consumer就类似于上面的产品经理、测试同事和开发小B</li><li>consumer group-A就类似于测试同事的集合。</li></ul><h2 id="各个组件" tabindex="-1"><a class="header-anchor" href="#各个组件"><span>各个组件</span></a></h2><ul><li>producer：生产者，就是消息的发送者。它会将消息发送给Broker。</li><li>producergroup：顾名思义，生产者组，它用于标识一类生产者。比如发送事务消息时，当一个生产者挂了后，broker可以找同一个生产组里的另一个生产者来确认事务的情况。</li><li>nameSrv：名字服务，类比为一个看板，实际上它就是一个路由注册中心。Broker会定时上传自身信息给nameSrv。这样生产者和消费者就可以从nameSrv上获取这些信息，从而能够顺利的发送和接收消息。</li><li>Broker：代理服务器，也就是消息中转站，它主要负责消息的存储、投递、查询。</li><li>Broker Cluster：代理服务器集群，都知道一个服务是脆弱的，假设就一个broker,万一宕机了僦无法正常处理消息。</li><li>consumer：消费者，用来消费消息。可以从Broker拉取自己想要的消息。</li><li>consumergroup：消费者组，同个消息是能够被不同的消费者进行消费的，对于同一个组而言，消费模式有集群消费（组内负载均衡地消费消息）和广播消费（组内所有成员都消费从消费组接到的消息）两种。</li></ul><p>Topic：主题，理解成消费的分类。例如体育、音乐、新闻等，生产者往指定主题发送消息，消费者可以选择对应主题进行消费。通过主题可以过滤不需要的消息，避免无关消息的打扰。</p><p>Tag：属于二级分类，例如体育主题中的足球主题感兴趣，就可以在体育主题的消息上带上tag标记这个消息是来自足球的。</p>',18))])}const q=a(h,[["render",_],["__file","basic.html.vue"]]),x=JSON.parse('{"path":"/framework/middleware/rocketmq/basic.html","title":"RocketMQ - 基础","lang":"zh-CN","frontmatter":{"description":"RocketMQ - 基础 学习任何东西需要先有一个整体的认识，然后再深入学习，钻研细节，最后再抓住核心脉络，总结整理消化在自己脑海中形成体系。 什么是消息队列 从消息的传递入手，这就是我们开发经常会遇到的： 随着消息越来越大，避免消息的丢失，引入了中转站的概念，和微信的未读消息一致会有一种方式提醒消息的消费者： 但是，一个中转站也可能存不下这么多消息...","head":[["meta",{"property":"og:url","content":"https://111/framework/middleware/rocketmq/basic.html"}],["meta",{"property":"og:site_name","content":"C++ 全栈知识体系"}],["meta",{"property":"og:title","content":"RocketMQ - 基础"}],["meta",{"property":"og:description","content":"RocketMQ - 基础 学习任何东西需要先有一个整体的认识，然后再深入学习，钻研细节，最后再抓住核心脉络，总结整理消化在自己脑海中形成体系。 什么是消息队列 从消息的传递入手，这就是我们开发经常会遇到的： 随着消息越来越大，避免消息的丢失，引入了中转站的概念，和微信的未读消息一致会有一种方式提醒消息的消费者： 但是，一个中转站也可能存不下这么多消息..."}],["meta",{"property":"og:type","content":"article"}],["meta",{"property":"og:locale","content":"zh-CN"}],["meta",{"property":"og:updated_time","content":"2024-12-01T10:38:24.000Z"}],["meta",{"property":"article:modified_time","content":"2024-12-01T10:38:24.000Z"}],["script",{"type":"application/ld+json"},"{\\"@context\\":\\"https://schema.org\\",\\"@type\\":\\"Article\\",\\"headline\\":\\"RocketMQ - 基础\\",\\"image\\":[\\"\\"],\\"dateModified\\":\\"2024-12-01T10:38:24.000Z\\",\\"author\\":[]}"]]},"headers":[{"level":2,"title":"各个组件","slug":"各个组件","link":"#各个组件","children":[]}],"git":{"updatedTime":1733049504000,"contributors":[{"name":"klc407073648","email":"407073648@qq.com","commits":1,"url":"https://github.com/klc407073648"}]},"filePathRelative":"framework/middleware/rocketmq/basic.md","autoDesc":true,"excerpt":"\\n\\n<blockquote>\\n<p>学习任何东西需要先有一个整体的认识，然后再深入学习，钻研细节，最后再抓住核心脉络，总结整理消化在自己脑海中形成体系。</p>\\n</blockquote>\\n<h1>什么是消息队列</h1>\\n<p>从消息的传递入手，这就是我们开发经常会遇到的：</p>\\n<p></p>\\n<p>随着消息越来越大，避免消息的丢失，引入了中转站的概念，和微信的未读消息一致会有一种方式提醒消息的消费者：</p>\\n<p></p>\\n<p>但是，一个中转站也可能存不下这么多消息，因此想到了扩展中转站：</p>\\n<p></p>\\n<p>但是随着中转站变多，发送者和消费者如何知道消息应该发到哪个中转站或者从哪个中转站读取消息呢？</p>"}');export{q as comp,x as data};