You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@rocketmq.apache.org by wi...@gmail.com, wi...@gmail.com on 2018/10/22 02:57:08 UTC

���������������rocketm���������������

Hi.
    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。

thanx
Best wish.
  will.

Re:业务层收到rocketm的心跳消费

Posted by Shannon <li...@163.com>.
Hello,<br/>       日志和系统环境相关的信息提供一下。<br/>       另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
>Hi.
>    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
>{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
>(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
>
>thanx
>Best wish.
>  will.

Re: ���������������������������������������������rocketm���������������������������������������������

Posted by wi...@gmail.com, wi...@gmail.com.
找到原因了,是我们使用的客户端的bug。

On 2018/10/26 08:11:50, will.happy.willing@gmail.com <wi...@gmail.com> wrote: 
> 当前看像是 broker端的bug 惊讶🙀
> 
> On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> > 
> > 
> > 
> > Hello,
> > 日志和系统环境相关的信息提供一下。
> > 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> > 
> > 
> > 
> > 
> > 
> > 
> > 
> > 
> > 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> > >Hi.
> > >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> > >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> > >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> > >
> > >thanx
> > >Best wish.
> > >  will.
> > 
> 

Re: ���������������rocketm���������������

Posted by wi...@gmail.com, wi...@gmail.com.
当前看像是 broker端的bug 惊讶🙀

On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> 
> 
> 
> Hello,
> 日志和系统环境相关的信息提供一下。
> 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> 
> 
> 
> 
> 
> 
> 
> 
> 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> >Hi.
> >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> >
> >thanx
> >Best wish.
> >  will.
> 

Re: ���������������rocketm���������������

Posted by wi...@gmail.com, wi...@gmail.com.
布署环境:
两个namesrv, 4个broker,两主两备
broker配置:
brokerClusterName=rbcycle_wan
brokerName=broker-a
brokerId=0
brokerRole=MASTER
namesrvAddr=xxxxxxxx
brokerIP1=xxxxxxxx
brokerIP2=xxxxxxxx
listenPort=10911
deleteWhen=04
fileReservedTime=48
flushDiskType=ASYNC_FLUSH
rocketmqHome=/opt/rocketmq/
storePathRootDir=/opt/rocketmq/data/
storePathCommitLog=/opt/rocketmq/data/commitlog/
storePathConsumerQueue=/opt/rocketmq/data/consumequeue/
autoCreateTopicEnable=false
autoCreateSubscriptionGroup=false
sendMessageThreadPoolNums=256
pullMessageThreadPoolNums=256
#64m
maxMessageSize=67108864
#64m
maxTransferBytesOnMessageInMemory=67108864
maxTransferCountOnMessageInMemory=1000
maxTransferBytesOnMessageInDisk=67108864
maxTransferCountOnMessageInDisk=100
accessMessageInMemoryMaxRatio=40
messageIndexEnable=false
maxMsgsNumBatch=512
serverChannelMaxIdleTimeSeconds=300 #默认120
clientChannelMaxIdleTimeSeconds=300

rocketmq的版本:4.2.0

日志:
{msgId=AC13384C00002A9F00000421194DEA2E,queueId=12,storeSize=1620,sysFlag=0,queueOffset=205761790,commitLogOffset=4540204968494,preparedTransactionOffset=0,bornTimestamp=1540292849801,bornHost=172.16.204.127:2748,storeHost=xxx.xxx.xx.xx:40746,storeTimestamp=1540292849807,reconsumeTimes=0,bodyCRC=1870354735,Message={m_topic=topic-xxxxx-xxxx,m_flag=0,properties={CONTENT_ENCODING=gzip,KEYS=KEY,MAX_OFFSET=205761791,MIN_OFFSET=200911434,TAGS=*,WAIT=true},m_bodyLen=1466}}| message len|1466|

期待您的回复。
Best wish
Will.

On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> 
> 
> 
> Hello,
> 日志和系统环境相关的信息提供一下。
> 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> 
> 
> 
> 
> 
> 
> 
> 
> 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> >Hi.
> >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> >
> >thanx
> >Best wish.
> >  will.
> 

Re: ���������������������������������������������������������������������������������������������������������������������������������������rocketm���������������������������������������������������������������������������������������������������������������������������������������

Posted by wi...@gmail.com, wi...@gmail.com.
当前分析看,整个数据是收到了,前面消息头的解析是正常的,实际上后面body的部份解析也是正常的,不过唯一有问题的是body部份前半部份是一个心跳的数据,但理论上是不应该出现在 这里的。

On 2018/10/24 09:30:38, will.happy.willing@gmail.com <wi...@gmail.com> wrote: 
> 这条数据除去前面必跳的部份,后面正好是我们的真实数据,只不过是经过压缩的。可以正常解压。
> 
> On 2018/10/24 08:07:57, will.happy.willing@gmail.com <wi...@gmail.com> wrote: 
> > 新发现的一条错误日志:
> > ERROR|^@^@^A^U^@^@^@\{"code":34,"language":"CPP","version":79,"opaque":79877,"flag":0,"remark":"","extFields":{}}{"clientID":"xxxxxxxxxxxx@7E59D616-D6AC-11E8-ACE2-525400F4FB6F","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"xxxxxxxxxxxxxx"}]}
> > ^_<8b>^H^@^@^@^@^@^@ÿÝ<9c>}k$7^L<87>¿J<99>¿s<8b>Þ-å«^\åX<9a>ä^Zî%áv<8f>ö8òÝ+o<8f>²<81>1^Tl^XO^H!d6»ã'²¤<9f>d{~.ç§óñór<8b>^@7Ë·§¿NËíû<9f>Ëé|ÿ¼Ü.ÏßO^?<9e><8f>§OïN÷_ïÞýñôõëróÛòåôñÃã]¾Å<8b>*2CäÅï<97>+¨Á^F<82>Fyéñüøå>/ª^@^E¹^D<86>Õ·ß<9f><8f>ËíÏåáóñc¾úr³^\<9f><9f>?ÝÿÈûÝÉCp°@) ~w¼G<ÊCñz×çÏÇóÃÓ·/ùg<8f>ËÍrÿ÷ù[ý<98>ü¼^_^_^^ë`±Ð^Aí@ ^G¤Rßrw:_^Fº`Ô<97>ü@R^N¨¾¼¼ÜüOF^Ae×ðBÿ1:<93>)^Q ÍÅ^Hy       ^N~<88>><&p^S/2<99>     ÿÅ£H^Cö^A¢æØHòÇ<8c><80>Ì^GÄNÀ<80>@P^O<9d>^NPÒ<82>é<82>Ð^G(Lèfæ<93>y`}©Òa~[§^M<9d>Ã2¼Â[<9d>¤.<88>E¢DÃ<86>e<82>LÑÍh¢ÅÈËd<8c><83>2<85>@¤^O^FZ<99>^KïÚ<84>Ð<9b>,^R<84><8b>iKÐÌÀ<88>Ô<99>ñ<8d>Ó^]9%Í<9c><8c><90>ó^UK'c~ZF^[<99><8d>q<98>+<82>ç^\UÄ7<89><97><82>Æ2­<86>Ë\xW   ^_¹w<82>^V)^Q<80>SNÐ^A²[<98>ó÷^\ã 
> > dÙâ<97>^M^F<99>^Ñ<96>^\"<92>?æB¼^N¤ <9d><9a>Æ­ Pàdf^\É^XD¬^\9¹^X¯¦*õÖ<88>^R<84>)NËdºfX}<91>¢Æ£<94>,¤Ö^A}ïñT5+|0ÅF°Ù
> > ðj<92>rgNTcÉ^Q:M<86>8HÕ`V<87>!^H­úi^B^KvgD¥^B<96>®Ès!^<97>O¥s<96>¢²<8a>'Õd<91>fd<89>HiF^Urn0ƾ=Q<88>#ÄÕ^[<9e>¸s<ô^L5á^D<8d>8º^UÞU é<95>l^U0<88
> > b>§Ò
> > 4[!^9aþû»<83>iÞJ5^ZEþÞg©iê5åuIJ<97>Nøæ<95>E§h£R$TAW;ÂÛ1þZ<9a>ñCg¾^W^S2s<8e>Õ<±)ß^XÕÍ5Ì<94>L^T«qf;ÀëPÚ¹¾<8d><82><9a><86>t{³6^Lż^Q<97>^Us^D<99
> > a>^áM<97>Ê ^XVsÅö<8c>#6bTÑ<96>Ê6Ö×¹·<9e>¨#^Vò³²ð<92><9a>f²`3*ák<80>^V^K<9a>,^Y^û!w^VN<95>^QH^YV+<8b>ý<9b>Pò?^ELë^]oºD<9f>]» jú <9a>H#Æl^Eøª<81>Ñ;GÝ1Ä^P^Z~8^C£÷¶<83>ÝE=X^[¡t+Æ<91>-}#­k¤¥¡Ûvï<8b>(uST<86><9c><86>¦Ù= $¡<93>^F­®;Má<88>9<88>ÎõC5bðÀI^Cê¥ÊïÝB«R<82>M¹ÑÉØv¢v'}<83>P-^@³<99>pÜ 
> > þRá^T¥<84>ëûövo?^E7^SÈ1Î<88>7"Q^T<88>ô?i^U^Vô^Fâ(<84>©<8b>P4<8c>¸^Uãõâao#*¥wíÒ<94>F<9c>Ù
> > q`}ï^^T°^UH·^Eì<8f>3hI<98>wXÝÒ¶5Þ^@ûE)¡^QÅæõÁÞ¢<82>ÍLëúaCsïÞ<86>h¬ùQ´~^Ná-^@<8a><92>^@CKÌL<90>^Lûw°<93>g¤<91><9c>^S3öÚ1^M<89>©iJ£8ÜýD%5¬g<9ee
> > >ZÑ<94>÷^NXõ^L<82>Áú±µ­^A^G´ó      ^]<88> Ñ^?Ú
> > oh«T<9c>^YÈ©ÑÎ^?^Cs4=PÒ ^[Qf+À«<93>^VÜYÝWI^SJ<99>3æB^\(i2^]^VâV¦Ø^VpÄQ^RóDLÀ<86>(Ýx<92>^6aôo<9c>%°<9c>«<93>%ÃWg+;÷ìIm^Cs 4Öd&0cï6<8c>(¨Y^_æ0çB<84>^K^^^]¤3ç|
> > 
> > On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> > > 
> > > 
> > > 
> > > Hello,
> > > 日志和系统环境相关的信息提供一下。
> > > 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> > > 
> > > 
> > > 
> > > 
> > > 
> > > 
> > > 
> > > 
> > > 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> > > >Hi.
> > > >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> > > >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> > > >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> > > >
> > > >thanx
> > > >Best wish.
> > > >  will.
> > > 
> > 
> 

Re: ���������������������������������������������rocketm���������������������������������������������

Posted by wi...@gmail.com, wi...@gmail.com.
这条数据除去前面必跳的部份,后面正好是我们的真实数据,只不过是经过压缩的。可以正常解压。

On 2018/10/24 08:07:57, will.happy.willing@gmail.com <wi...@gmail.com> wrote: 
> 新发现的一条错误日志:
> ERROR|^@^@^A^U^@^@^@\{"code":34,"language":"CPP","version":79,"opaque":79877,"flag":0,"remark":"","extFields":{}}{"clientID":"xxxxxxxxxxxx@7E59D616-D6AC-11E8-ACE2-525400F4FB6F","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"xxxxxxxxxxxxxx"}]}
> ^_<8b>^H^@^@^@^@^@^@ÿÝ<9c>}k$7^L<87>¿J<99>¿s<8b>Þ-å«^\åX<9a>ä^Zî%áv<8f>ö8òÝ+o<8f>²<81>1^Tl^XO^H!d6»ã'²¤<9f>d{~.ç§óñór<8b>^@7Ë·§¿NËíû<9f>Ëé|ÿ¼Ü.ÏßO^?<9e><8f>§OïN÷_ïÞýñôõëróÛòåôñÃã]¾Å<8b>*2CäÅï<97>+¨Á^F<82>Fyéñüøå>/ª^@^E¹^D<86>Õ·ß<9f><8f>ËíÏåáóñc¾úr³^\<9f><9f>?ÝÿÈûÝÉCp°@) ~w¼G<ÊCñz×çÏÇóÃÓ·/ùg<8f>ËÍrÿ÷ù[ý<98>ü¼^_^_^^ë`±Ð^Aí@ ^G¤Rßrw:_^Fº`Ô<97>ü@R^N¨¾¼¼ÜüOF^Ae×ðBÿ1:<93>)^Q ÍÅ^Hy       ^N~<88>><&p^S/2<99>     ÿÅ£H^Cö^A¢æØHòÇ<8c><80>Ì^GÄNÀ<80>@P^O<9d>^NPÒ<82>é<82>Ð^G(Lèfæ<93>y`}©Òa~[§^M<9d>Ã2¼Â[<9d>¤.<88>E¢DÃ<86>e<82>LÑÍh¢ÅÈËd<8c><83>2<85>@¤^O^FZ<99>^KïÚ<84>Ð<9b>,^R<84><8b>iKÐÌÀ<88>Ô<99>ñ<8d>Ó^]9%Í<9c><8c><90>ó^UK'c~ZF^[<99><8d>q<98>+<82>ç^\UÄ7<89><97><82>Æ2­<86>Ë\xW   ^_¹w<82>^V)^Q<80>SNÐ^A²[<98>ó÷^\ã 
> dÙâ<97>^M^F<99>^Ñ<96>^\"<92>?æB¼^N¤ <9d><9a>Æ­ Pàdf^\É^XD¬^\9¹^X¯¦*õÖ<88>^R<84>)NËdºfX}<91>¢Æ£<94>,¤Ö^A}ïñT5+|0ÅF°Ù
> ðj<92>rgNTcÉ^Q:M<86>8HÕ`V<87>!^H­úi^B^KvgD¥^B<96>®Ès!^<97>O¥s<96>¢²<8a>'Õd<91>fd<89>HiF^Urn0ƾ=Q<88>#ÄÕ^[<9e>¸s<ô^L5á^D<8d>8º^UÞU é<95>l^U0<88
> b>§Ò
> 4[!^9aþû»<83>iÞJ5^ZEþÞg©iê5åuIJ<97>Nøæ<95>E§h£R$TAW;ÂÛ1þZ<9a>ñCg¾^W^S2s<8e>Õ<±)ß^XÕÍ5Ì<94>L^T«qf;ÀëPÚ¹¾<8d><82><9a><86>t{³6^Lż^Q<97>^Us^D<99
> a>^áM<97>Ê ^XVsÅö<8c>#6bTÑ<96>Ê6Ö×¹·<9e>¨#^Vò³²ð<92><9a>f²`3*ák<80>^V^K<9a>,^Y^û!w^VN<95>^QH^YV+<8b>ý<9b>Pò?^ELë^]oºD<9f>]» jú <9a>H#Æl^Eøª<81>Ñ;GÝ1Ä^P^Z~8^C£÷¶<83>ÝE=X^[¡t+Æ<91>-}#­k¤¥¡Ûvï<8b>(uST<86><9c><86>¦Ù= $¡<93>^F­®;Má<88>9<88>ÎõC5bðÀI^Cê¥ÊïÝB«R<82>M¹ÑÉØv¢v'}<83>P-^@³<99>pÜ 
> þRá^T¥<84>ëûövo?^E7^SÈ1Î<88>7"Q^T<88>ô?i^U^Vô^Fâ(<84>©<8b>P4<8c>¸^Uãõâao#*¥wíÒ<94>F<9c>Ù
> q`}ï^^T°^UH·^Eì<8f>3hI<98>wXÝÒ¶5Þ^@ûE)¡^QÅæõÁÞ¢<82>ÍLëúaCsïÞ<86>h¬ùQ´~^Ná-^@<8a><92>^@CKÌL<90>^Lûw°<93>g¤<91><9c>^S3öÚ1^M<89>©iJ£8ÜýD%5¬g<9ee
> >ZÑ<94>÷^NXõ^L<82>Áú±µ­^A^G´ó      ^]<88> Ñ^?Ú
> oh«T<9c>^YÈ©ÑÎ^?^Cs4=PÒ ^[Qf+À«<93>^VÜYÝWI^SJ<99>3æB^\(i2^]^VâV¦Ø^VpÄQ^RóDLÀ<86>(Ýx<92>^6aôo<9c>%°<9c>«<93>%ÃWg+;÷ìIm^Cs 4Öd&0cï6<8c>(¨Y^_æ0çB<84>^K^^^]¤3ç|
> 
> On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> > 
> > 
> > 
> > Hello,
> > 日志和系统环境相关的信息提供一下。
> > 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> > 
> > 
> > 
> > 
> > 
> > 
> > 
> > 
> > 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> > >Hi.
> > >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> > >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> > >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> > >
> > >thanx
> > >Best wish.
> > >  will.
> > 
> 

Re: ���������������rocketm���������������

Posted by wi...@gmail.com, wi...@gmail.com.
新发现的一条错误日志:
ERROR|^@^@^A^U^@^@^@\{"code":34,"language":"CPP","version":79,"opaque":79877,"flag":0,"remark":"","extFields":{}}{"clientID":"xxxxxxxxxxxx@7E59D616-D6AC-11E8-ACE2-525400F4FB6F","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"xxxxxxxxxxxxxx"}]}
^_<8b>^H^@^@^@^@^@^@ÿÝ<9c>}k$7^L<87>¿J<99>¿s<8b>Þ-å«^\åX<9a>ä^Zî%áv<8f>ö8òÝ+o<8f>²<81>1^Tl^XO^H!d6»ã'²¤<9f>d{~.ç§óñór<8b>^@7Ë·§¿NËíû<9f>Ëé|ÿ¼Ü.ÏßO^?<9e><8f>§OïN÷_ïÞýñôõëróÛòåôñÃã]¾Å<8b>*2CäÅï<97>+¨Á^F<82>Fyéñüøå>/ª^@^E¹^D<86>Õ·ß<9f><8f>ËíÏåáóñc¾úr³^\<9f><9f>?ÝÿÈûÝÉCp°@) ~w¼G<ÊCñz×çÏÇóÃÓ·/ùg<8f>ËÍrÿ÷ù[ý<98>ü¼^_^_^^ë`±Ð^Aí@ ^G¤Rßrw:_^Fº`Ô<97>ü@R^N¨¾¼¼ÜüOF^Ae×ðBÿ1:<93>)^Q ÍÅ^Hy       ^N~<88>><&p^S/2<99>     ÿÅ£H^Cö^A¢æØHòÇ<8c><80>Ì^GÄNÀ<80>@P^O<9d>^NPÒ<82>é<82>Ð^G(Lèfæ<93>y`}©Òa~[§^M<9d>Ã2¼Â[<9d>¤.<88>E¢DÃ<86>e<82>LÑÍh¢ÅÈËd<8c><83>2<85>@¤^O^FZ<99>^KïÚ<84>Ð<9b>,^R<84><8b>iKÐÌÀ<88>Ô<99>ñ<8d>Ó^]9%Í<9c><8c><90>ó^UK'c~ZF^[<99><8d>q<98>+<82>ç^\UÄ7<89><97><82>Æ2­<86>Ë\xW   ^_¹w<82>^V)^Q<80>SNÐ^A²[<98>ó÷^\ã 
dÙâ<97>^M^F<99>^Ñ<96>^\"<92>?æB¼^N¤ <9d><9a>Æ­ Pàdf^\É^XD¬^\9¹^X¯¦*õÖ<88>^R<84>)NËdºfX}<91>¢Æ£<94>,¤Ö^A}ïñT5+|0ÅF°Ù
ðj<92>rgNTcÉ^Q:M<86>8HÕ`V<87>!^H­úi^B^KvgD¥^B<96>®Ès!^<97>O¥s<96>¢²<8a>'Õd<91>fd<89>HiF^Urn0ƾ=Q<88>#ÄÕ^[<9e>¸s<ô^L5á^D<8d>8º^UÞU é<95>l^U0<88
b>§Ò
4[!^9aþû»<83>iÞJ5^ZEþÞg©iê5åuIJ<97>Nøæ<95>E§h£R$TAW;ÂÛ1þZ<9a>ñCg¾^W^S2s<8e>Õ<±)ß^XÕÍ5Ì<94>L^T«qf;ÀëPÚ¹¾<8d><82><9a><86>t{³6^Lż^Q<97>^Us^D<99
a>^áM<97>Ê ^XVsÅö<8c>#6bTÑ<96>Ê6Ö×¹·<9e>¨#^Vò³²ð<92><9a>f²`3*ák<80>^V^K<9a>,^Y^û!w^VN<95>^QH^YV+<8b>ý<9b>Pò?^ELë^]oºD<9f>]» jú <9a>H#Æl^Eøª<81>Ñ;GÝ1Ä^P^Z~8^C£÷¶<83>ÝE=X^[¡t+Æ<91>-}#­k¤¥¡Ûvï<8b>(uST<86><9c><86>¦Ù= $¡<93>^F­®;Má<88>9<88>ÎõC5bðÀI^Cê¥ÊïÝB«R<82>M¹ÑÉØv¢v'}<83>P-^@³<99>pÜ 
þRá^T¥<84>ëûövo?^E7^SÈ1Î<88>7"Q^T<88>ô?i^U^Vô^Fâ(<84>©<8b>P4<8c>¸^Uãõâao#*¥wíÒ<94>F<9c>Ù
q`}ï^^T°^UH·^Eì<8f>3hI<98>wXÝÒ¶5Þ^@ûE)¡^QÅæõÁÞ¢<82>ÍLëúaCsïÞ<86>h¬ùQ´~^Ná-^@<8a><92>^@CKÌL<90>^Lûw°<93>g¤<91><9c>^S3öÚ1^M<89>©iJ£8ÜýD%5¬g<9ee
>ZÑ<94>÷^NXõ^L<82>Áú±µ­^A^G´ó      ^]<88> Ñ^?Ú
oh«T<9c>^YÈ©ÑÎ^?^Cs4=PÒ ^[Qf+À«<93>^VÜYÝWI^SJ<99>3æB^\(i2^]^VâV¦Ø^VpÄQ^RóDLÀ<86>(Ýx<92>^6aôo<9c>%°<9c>«<93>%ÃWg+;÷ìIm^Cs 4Öd&0cï6<8c>(¨Y^_æ0çB<84>^K^^^]¤3ç|

On 2018/10/23 02:22:26, Shannon  <li...@163.com> wrote: 
> 
> 
> 
> Hello,
> 日志和系统环境相关的信息提供一下。
> 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
> 
> 
> 
> 
> 
> 
> 
> 
> 在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
> >Hi.
> >    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> >
> >thanx
> >Best wish.
> >  will.
> 

Re:业务层收到rocketm的心跳消费

Posted by Shannon <li...@163.com>.


Hello,
日志和系统环境相关的信息提供一下。
另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。








在 2018-10-22 10:57:08,"will.happy.willing@gmail.com" <wi...@gmail.com> 写道:
>Hi.
>    rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
>{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
>(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
>
>thanx
>Best wish.
>  will.