| "use strict";(self.webpackChunkrocketmq_docs=self.webpackChunkrocketmq_docs||[]).push([[4720],{15680:(e,t,n)=>{n.d(t,{xA:()=>g,yg:()=>y});var r=n(96540);function s(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function o(e,t){var n=Object.keys(e);if(Object.getOwnPropertySymbols){var r=Object.getOwnPropertySymbols(e);t&&(r=r.filter((function(t){return Object.getOwnPropertyDescriptor(e,t).enumerable}))),n.push.apply(n,r)}return n}function a(e){for(var t=1;t<arguments.length;t++){var n=null!=arguments[t]?arguments[t]:{};t%2?o(Object(n),!0).forEach((function(t){s(e,t,n[t])})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(n)):o(Object(n)).forEach((function(t){Object.defineProperty(e,t,Object.getOwnPropertyDescriptor(n,t))}))}return e}function p(e,t){if(null==e)return{};var n,r,s=function(e,t){if(null==e)return{};var n,r,s={},o=Object.keys(e);for(r=0;r<o.length;r++)n=o[r],t.indexOf(n)>=0||(s[n]=e[n]);return s}(e,t);if(Object.getOwnPropertySymbols){var o=Object.getOwnPropertySymbols(e);for(r=0;r<o.length;r++)n=o[r],t.indexOf(n)>=0||Object.prototype.propertyIsEnumerable.call(e,n)&&(s[n]=e[n])}return s}var i=r.createContext({}),c=function(e){var t=r.useContext(i),n=t;return e&&(n="function"==typeof e?e(t):a(a({},t),e)),n},g=function(e){var t=c(e.components);return r.createElement(i.Provider,{value:t},e.children)},u="mdxType",l={inlineCode:"code",wrapper:function(e){var t=e.children;return r.createElement(r.Fragment,{},t)}},m=r.forwardRef((function(e,t){var n=e.components,s=e.mdxType,o=e.originalType,i=e.parentName,g=p(e,["components","mdxType","originalType","parentName"]),u=c(n),m=s,y=u["".concat(i,".").concat(m)]||u[m]||l[m]||o;return n?r.createElement(y,a(a({ref:t},g),{},{components:n})):r.createElement(y,a({ref:t},g))}));function y(e,t){var n=arguments,s=t&&t.mdxType;if("string"==typeof e||s){var o=n.length,a=new Array(o);a[0]=m;var p={};for(var i in t)hasOwnProperty.call(t,i)&&(p[i]=t[i]);p.originalType=e,p[u]="string"==typeof e?e:s,a[1]=p;for(var c=2;c<o;c++)a[c]=n[c];return r.createElement.apply(null,a)}return r.createElement.apply(null,n)}m.displayName="MDXCreateElement"},49767:(e,t,n)=>{n.r(t),n.d(t,{assets:()=>i,contentTitle:()=>a,default:()=>l,frontMatter:()=>o,metadata:()=>p,toc:()=>c});var r=n(58168),s=(n(96540),n(15680));const o={},a="\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4",p={unversionedId:"bestPractice/07subscribe",id:"bestPractice/07subscribe",title:"\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4",description:"\u524d\u8a00",source:"@site/docs/05-bestPractice/07subscribe.md",sourceDirName:"05-bestPractice",slug:"/bestPractice/07subscribe",permalink:"/zh/docs/4.x/bestPractice/07subscribe",draft:!1,editUrl:"https://github.com/apache/rocketmq-site/tree/new-official-website/docs/05-bestPractice/07subscribe.md",tags:[],version:"current",frontMatter:{},sidebar:"myAutogeneratedSidebar",previous:{title:"\u65e5\u5fd7\u914d\u7f6e",permalink:"/zh/docs/4.x/bestPractice/06log"},next:{title:"\u5e38\u89c1\u95ee\u9898\u89e3\u7b54",permalink:"/zh/docs/4.x/bestPractice/08FAQ"}},i={},c=[{value:"\u524d\u8a00",id:"\u524d\u8a00",level:2},{value:"1 \u6b63\u786e\u8ba2\u9605\u5173\u7cfb\u793a\u4f8b",id:"1--\u6b63\u786e\u8ba2\u9605\u5173\u7cfb\u793a\u4f8b",level:2},{value:"1.1 \u8ba2\u9605\u4e00\u4e2aTopic\u4e14\u8ba2\u9605\u4e00\u4e2aTag",id:"11-\u8ba2\u9605\u4e00\u4e2atopic\u4e14\u8ba2\u9605\u4e00\u4e2atag",level:3},{value:"1.2 \u8ba2\u9605\u4e00\u4e2aTopic\u4e14\u8ba2\u9605\u591a\u4e2aTag",id:"12-\u8ba2\u9605\u4e00\u4e2atopic\u4e14\u8ba2\u9605\u591a\u4e2atag",level:3},{value:"1.3 \u8ba2\u9605\u591a\u4e2aTopic\u4e14\u8ba2\u9605\u591a\u4e2aTag",id:"13-\u8ba2\u9605\u591a\u4e2atopic\u4e14\u8ba2\u9605\u591a\u4e2atag",level:3},{value:"2 \u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u7684\u6392\u67e5",id:"2-\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u7684\u6392\u67e5",level:2},{value:"3 \u5e38\u89c1\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u95ee\u9898",id:"3-\u5e38\u89c1\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u95ee\u9898",level:2},{value:"3.1 \u540c\u4e00Group ID\u4e0b\u7684Consumer\u5b9e\u4f8b\u8ba2\u9605\u7684Topic\u4e0d\u540c",id:"31-\u540c\u4e00group-id\u4e0b\u7684consumer\u5b9e\u4f8b\u8ba2\u9605\u7684topic\u4e0d\u540c",level:3},{value:"3.2 \u540c\u4e00Group ID\u4e0b\u7684Consumer\u5b9e\u4f8b\u8ba2\u9605\u7684Topic\u76f8\u540c\uff0c\u4f46\u8ba2\u9605\u7684Tag\u4e0d\u4e00\u81f4",id:"32-\u540c\u4e00group-id\u4e0b\u7684consumer\u5b9e\u4f8b\u8ba2\u9605\u7684topic\u76f8\u540c\u4f46\u8ba2\u9605\u7684tag\u4e0d\u4e00\u81f4",level:3}],g={toc:c},u="wrapper";function l(e){let{components:t,...o}=e;return(0,s.yg)(u,(0,r.A)({},g,o,{components:t,mdxType:"MDXLayout"}),(0,s.yg)("h1",{id:"\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4"},"\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4"),(0,s.yg)("h2",{id:"\u524d\u8a00"},"\u524d\u8a00"),(0,s.yg)("p",null,"\u8ba2\u9605\u5173\u7cfb\uff1a\u4e00\u4e2a\u6d88\u8d39\u8005\u7ec4\u8ba2\u9605\u4e00\u4e2a Topic \u7684\u67d0\u4e00\u4e2a Tag\uff0c\u8fd9\u79cd\u8bb0\u5f55\u88ab\u79f0\u4e3a\u8ba2\u9605\u5173\u7cfb\u3002"),(0,s.yg)("p",null,"\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\uff1a\u540c\u4e00\u4e2a\u6d88\u8d39\u8005\u7ec4\u4e0b\u6240\u6709\u6d88\u8d39\u8005\u5b9e\u4f8b\u6240\u8ba2\u9605\u7684Topic\u3001Tag\u5fc5\u987b\u5b8c\u5168\u4e00\u81f4\u3002\u5982\u679c\u8ba2\u9605\u5173\u7cfb\uff08\u6d88\u8d39\u8005\u7ec4\u540d-Topic-Tag\uff09\u4e0d\u4e00\u81f4\uff0c\u4f1a\u5bfc\u81f4\u6d88\u8d39\u6d88\u606f\u7d0a\u4e71\uff0c\u751a\u81f3\u6d88\u606f\u4e22\u5931\u3002"),(0,s.yg)("h2",{id:"1--\u6b63\u786e\u8ba2\u9605\u5173\u7cfb\u793a\u4f8b"},"1 \u6b63\u786e\u8ba2\u9605\u5173\u7cfb\u793a\u4f8b"),(0,s.yg)("h3",{id:"11-\u8ba2\u9605\u4e00\u4e2atopic\u4e14\u8ba2\u9605\u4e00\u4e2atag"},"1.1 \u8ba2\u9605\u4e00\u4e2aTopic\u4e14\u8ba2\u9605\u4e00\u4e2aTag"),(0,s.yg)("p",null,"\u5982\u4e0b\u56fe\u6240\u793a\uff0c\u540c\u4e00Group ID\u4e0b\u7684\u4e09\u4e2aConsumer\u5b9e\u4f8bC1\u3001C2\u548cC3\u5206\u522b\u90fd\u8ba2\u9605\u4e86TopicA\uff0c\u4e14\u8ba2\u9605TopicA\u7684Tag\u4e5f\u90fd\u662fTag1\uff0c\u7b26\u5408\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\u539f\u5219\u3002"),(0,s.yg)("p",null,(0,s.yg)("img",{alt:"1658453577894-0e64b114-cb4a-4220-a09a-62bc1f2943c6",src:n(5092).A,width:"662",height:"482"})),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u6b63\u786e\u793a\u4f8b\u4ee3\u7801\u4e00")),(0,s.yg)("p",null,"C1\u3001C2\u3001C3\u7684\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\uff0c\u5373C1\u3001C2\u3001C3\u8ba2\u9605\u6d88\u606f\u7684\u4ee3\u7801\u5fc5\u987b\u5b8c\u5168\u4e00\u81f4\uff0c\u4ee3\u7801\u793a\u4f8b\u5982\u4e0b\uff1a"),(0,s.yg)("pre",null,(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_1");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "Tag1", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n')),(0,s.yg)("h3",{id:"12-\u8ba2\u9605\u4e00\u4e2atopic\u4e14\u8ba2\u9605\u591a\u4e2atag"},"1.2 \u8ba2\u9605\u4e00\u4e2aTopic\u4e14\u8ba2\u9605\u591a\u4e2aTag"),(0,s.yg)("p",null,"\u5982\u4e0b\u56fe\u6240\u793a\uff0c\u540c\u4e00Group ID\u4e0b\u7684\u4e09\u4e2aConsumer\u5b9e\u4f8bC1\u3001C2\u548cC3\u5206\u522b\u90fd\u8ba2\u9605\u4e86TopicB\uff0c\u8ba2\u9605TopicB\u7684Tag\u4e5f\u90fd\u662fTag2\u548cTag3\uff0c\u8868\u793a\u8ba2\u9605TopicB\u4e2d\u6240\u6709Tag\u4e3aTag2\u6216Tag3\u7684\u6d88\u606f\uff0c\u4e14\u987a\u5e8f\u4e00\u81f4\u90fd\u662fTag2||Tag3\uff0c\u7b26\u5408\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\u6027\u539f\u5219\u3002"),(0,s.yg)("p",null,(0,s.yg)("img",{alt:"1658453865541-118b0cd0-d597-4a76-9561-ae765540567c",src:n(94949).A,width:"857",height:"610"})),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u6b63\u786e\u793a\u4f8b\u4ee3\u7801\u4e8c")),(0,s.yg)("p",null,"C1\u3001C2\u3001C3\u7684\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\uff0c\u5373C1\u3001C2\u3001C3\u8ba2\u9605\u6d88\u606f\u7684\u4ee3\u7801\u5fc5\u987b\u5b8c\u5168\u4e00\u81f4\uff0c\u4ee3\u7801\u793a\u4f8b\u5982\u4e0b\uff1a"),(0,s.yg)("pre",null,(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_2");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicB", "Tag2||Tag3", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n')),(0,s.yg)("h3",{id:"13-\u8ba2\u9605\u591a\u4e2atopic\u4e14\u8ba2\u9605\u591a\u4e2atag"},"1.3 \u8ba2\u9605\u591a\u4e2aTopic\u4e14\u8ba2\u9605\u591a\u4e2aTag"),(0,s.yg)("p",null,"\u5982\u4e0b\u56fe\u6240\u793a\uff0c\u540c\u4e00Group ID\u4e0b\u7684\u4e09\u4e2aConsumer\u5b9e\u4f8bC1\u3001C2\u548cC3\u5206\u522b\u90fd\u8ba2\u9605\u4e86TopicA\u548cTopicB\uff0c\u4e14\u8ba2\u9605\u7684TopicA\u90fd\u672a\u6307\u5b9aTag\uff0c\u5373\u8ba2\u9605TopicA\u4e2d\u7684\u6240\u6709\u6d88\u606f\uff0c\u8ba2\u9605\u7684TopicB\u7684Tag\u90fd\u662fTag2\u548cTag3\uff0c\u8868\u793a\u8ba2\u9605TopicB\u4e2d\u6240\u6709Tag\u4e3aTag2\u6216Tag3\u7684\u6d88\u606f\uff0c\u4e14\u987a\u5e8f\u4e00\u81f4\u90fd\u662fTag2||Tag3\uff0c\u7b26\u5408\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\u539f\u5219\u3002"),(0,s.yg)("p",null,(0,s.yg)("img",{alt:"1658454292557-c07fa0ac-81be-4aac-9c5b-342821c554a6",src:n(93566).A,width:"868",height:"616"})),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u6b63\u786e\u793a\u4f8b\u4ee3\u7801\u4e09")),(0,s.yg)("p",null,"C1\u3001C2\u3001C3\u7684\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\uff0c\u5373C1\u3001C2\u3001C3\u8ba2\u9605\u6d88\u606f\u7684\u4ee3\u7801\u5fc5\u987b\u5b8c\u5168\u4e00\u81f4\uff0c\u4ee3\u7801\u793a\u4f8b\u5982\u4e0b\uff1a"),(0,s.yg)("pre",null,(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_3");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "*", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n consumer.subscribe("TopicB", "Tag2||Tag3", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n')),(0,s.yg)("h2",{id:"2-\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u7684\u6392\u67e5"},"2 \u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u7684\u6392\u67e5"),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u95ee\u9898\u63cf\u8ff0")),(0,s.yg)("p",null,"\u5728\u4f7f\u7528\u6d88\u606f\u961f\u5217RocketMQ\u7248\u5b9e\u4f8b\u65f6\uff0c\u53ef\u80fd\u4f1a\u51fa\u73b0\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u7684\u60c5\u51b5\uff0c\u5177\u4f53\u7684\u95ee\u9898\u73b0\u8c61\u5982\u4e0b\uff1a"),(0,s.yg)("ul",null,(0,s.yg)("li",{parentName:"ul"},"\u6d88\u606f\u961f\u5217RocketMQ\u7248\u63a7\u5236\u53f0\u4e2d\u8ba2\u9605\u5173\u7cfb\u662f\u5426\u4e00\u81f4\u663e\u793a\u4e3a\u5426\u3002"),(0,s.yg)("li",{parentName:"ul"},"\u6d88\u8d39\u8005\uff08Consumer\uff09\u5b9e\u4f8b\u672a\u6536\u5230\u8ba2\u9605\u7684\u6d88\u606f\u3002")),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u8bf7\u53c2\u8003\u4ee5\u4e0b\u6b65\u9aa4\u8fdb\u884c\u68c0\u67e5")),(0,s.yg)("p",null,"\u60a8\u53ef\u5728\u6d88\u606f\u6d88\u606f\u961f\u5217RocketMQ\u7248\u63a7\u5236\u53f0Group \u8be6\u60c5\u9875\u9762\u67e5\u770b\u6307\u5b9aGroup\u7684\u8ba2\u9605\u5173\u7cfb\u662f\u5426\u4e00\u81f4\u3002\u82e5\u67e5\u8be2\u7ed3\u679c\u4e0d\u4e00\u81f4\uff0c\u8bf7\u53c2\u89c1\u672c\u6587(3 \u5e38\u89c1\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u95ee\u9898)\u6392\u67e5Consumer\u5b9e\u4f8b\u7684\u6d88\u8d39\u4ee3\u7801\u3002"),(0,s.yg)("ol",null,(0,s.yg)("li",{parentName:"ol"},"\u68c0\u67e5\u60a8Consumer\u5b9e\u4f8b\u4e2d\u4e0e\u8ba2\u9605\u76f8\u5173\u7684\u914d\u7f6e\u4ee3\u7801\uff0c\u786e\u4fdd\u914d\u7f6e\u540c\u4e00\u4e2aGroup ID\u7684\u6240\u6709Consumer\u5b9e\u4f8b\u5747\u8ba2\u9605\u76f8\u540c\u7684Topic\u53caTag\u3002"),(0,s.yg)("li",{parentName:"ol"},"\u91cd\u542f\u5ba2\u6237\u7aef\u5e94\u7528\u3002"),(0,s.yg)("li",{parentName:"ol"},"\u767b\u5f55",(0,s.yg)("a",{parentName:"li",href:"https://ons.console.aliyun.com/"},"\u6d88\u606f\u961f\u5217RocketMQ\u7248\u63a7\u5236\u53f0"),"\uff0c\u5728\u5de6\u4fa7\u5bfc\u822a\u680f\u4e2d\u5355\u51fb\u5b9e\u4f8b\u5217\u8868\uff0c\u9009\u62e9\u60a8\u7684\u76ee\u6807\u5b9e\u4f8b\uff0c\u8fdb\u5165\u5b9e\u4f8b\u8be6\u60c5\u9875\u9762\u3002"),(0,s.yg)("li",{parentName:"ol"},"\u5728\u5de6\u4fa7\u5bfc\u822a\u680f\u4e2d\u5355\u51fbGroup\u7ba1\u7406\uff0c\u9009\u62e9\u5bf9\u5e94\u7684\u534f\u8bae\u540e\uff0c\u5355\u51fb\u6d88\u8d39\u8005\u72b6\u6001\uff0c\u786e\u8ba4\u8ba2\u9605\u5173\u7cfb\u662f\u5426\u4e00\u81f4\u663e\u793a\u4e3a\u662f\u3002"),(0,s.yg)("li",{parentName:"ol"},"\u6d4b\u8bd5\u5e76\u786e\u8ba4\u6d88\u606f\u80fd\u591f\u88ab\u9884\u671f\u7684Consumer\u5b9e\u4f8b\u6240\u6d88\u8d39\u3002")),(0,s.yg)("h2",{id:"3-\u5e38\u89c1\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u95ee\u9898"},"3 \u5e38\u89c1\u8ba2\u9605\u5173\u7cfb\u4e0d\u4e00\u81f4\u95ee\u9898"),(0,s.yg)("h3",{id:"31-\u540c\u4e00group-id\u4e0b\u7684consumer\u5b9e\u4f8b\u8ba2\u9605\u7684topic\u4e0d\u540c"},"3.1 \u540c\u4e00Group ID\u4e0b\u7684Consumer\u5b9e\u4f8b\u8ba2\u9605\u7684Topic\u4e0d\u540c"),(0,s.yg)("p",null,"\u5982\u4e0b\u56fe\u6240\u793a\uff0c\u540c\u4e00Group ID\u4e0b\u7684\u4e09\u4e2aConsumer\u5b9e\u4f8bC1\u3001C2\u548cC3\u5206\u522b\u8ba2\u9605\u4e86TopicA\u3001TopicB\u548cTopicC\uff0c\u8ba2\u9605\u7684Topic\u4e0d\u4e00\u81f4\uff0c\u4e0d\u7b26\u5408\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\u6027\u539f\u5219\u3002"),(0,s.yg)("p",null,(0,s.yg)("img",{alt:"image-20220722102131073",src:n(1671).A,width:"881",height:"621"})),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u9519\u8bef\u793a\u4f8b\u4ee3\u7801\u4e00")),(0,s.yg)("ul",null,(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b1-1\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_1");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "*", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n });\n'))),(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b1-2\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_1");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicB", "*", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n });\n'))),(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b1-3\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_1");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicC", "*", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n });\n')))),(0,s.yg)("h3",{id:"32-\u540c\u4e00group-id\u4e0b\u7684consumer\u5b9e\u4f8b\u8ba2\u9605\u7684topic\u76f8\u540c\u4f46\u8ba2\u9605\u7684tag\u4e0d\u4e00\u81f4"},"3.2 \u540c\u4e00Group ID\u4e0b\u7684Consumer\u5b9e\u4f8b\u8ba2\u9605\u7684Topic\u76f8\u540c\uff0c\u4f46\u8ba2\u9605\u7684Tag\u4e0d\u4e00\u81f4"),(0,s.yg)("p",null,"\u5982\u4e0b\u56fe\u6240\u793a\uff0c\u540c\u4e00Group ID\u4e0b\u7684\u4e09\u4e2aConsumer\u5b9e\u4f8bC1\u3001C2\u548cC3\u5206\u522b\u90fd\u8ba2\u9605\u4e86TopicA\uff0c\u4f46\u662fC1\u8ba2\u9605TopicA\u7684Tag\u4e3a",(0,s.yg)("strong",{parentName:"p"},"Tag1"),"\uff0cC2\u548cC3\u8ba2\u9605\u7684TopicA\u7684Tag\u4e3a",(0,s.yg)("strong",{parentName:"p"},"Tag2"),"\uff0c\u8ba2\u9605\u540c\u4e00Topic\u7684Tag\u4e0d\u4e00\u81f4\uff0c\u4e0d\u7b26\u5408\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4\u6027\u539f\u5219\u3002"),(0,s.yg)("p",null,(0,s.yg)("img",{alt:"image-20220722102926055",src:n(57616).A,width:"867",height:"608"})),(0,s.yg)("p",null,(0,s.yg)("strong",{parentName:"p"},"\u9519\u8bef\u793a\u4f8b\u4ee3\u7801\u4e8c")),(0,s.yg)("ul",null,(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b2-1\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_2");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "Tag1", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n')))),(0,s.yg)("ul",null,(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b2-2\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_2");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "Tag2", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n'))),(0,s.yg)("li",{parentName:"ul"},(0,s.yg)("p",{parentName:"li"},"Consumer\u5b9e\u4f8b2-3\uff1a"),(0,s.yg)("pre",{parentName:"li"},(0,s.yg)("code",{parentName:"pre",className:"language-java"},' Properties properties = new Properties();\n properties.put(PropertyKeyConst.GROUP_ID, "GID_test_2");\n Consumer consumer = ONSFactory.createConsumer(properties);\n consumer.subscribe("TopicA", "Tag2", new MessageListener() {\n public Action consume(Message message, ConsumeContext context) {\n System.out.println(message.getMsgID());\n return Action.CommitMessage;\n }\n }); \n')))))}l.isMDXComponent=!0},5092:(e,t,n)=>{n.d(t,{A:()=>r});const r=n.p+"assets/images/4.x\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4-1-4cbab04c03d85562d7d144edfeb86aa6.jpeg"},94949:(e,t,n)=>{n.d(t,{A:()=>r});const r=n.p+"assets/images/4.x\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4-2-4ea9614e13393725496776d2a5668b43.jpeg"},93566:(e,t,n)=>{n.d(t,{A:()=>r});const r=n.p+"assets/images/4.x\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4-3-085b3104a879045cd04b876911351e21.jpeg"},1671:(e,t,n)=>{n.d(t,{A:()=>r});const r=n.p+"assets/images/4.x\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4-4-41010fd8c9c21c928807228caaf2d621.jpeg"},57616:(e,t,n)=>{n.d(t,{A:()=>r});const r=n.p+"assets/images/4.x\u8ba2\u9605\u5173\u7cfb\u4e00\u81f4-5-514888130c9907fb857a159181ff71cc.jpeg"}}]); |