• 2024-09-20springintegration handle message with messagid between three channels
    InSpringIntegration,handlingamessageacrossmultiplechannelswhilepreservingamessageId(orsimilaridentifier)canbeachievedbyleveragingmessagerouting,channels,andcustommessageheaders.Here’showyoucanrouteandprocessmessagesbetw
  • 2024-06-10Dubbo消费消息的唯一性
    在Dubbo中,如果要保证消息的唯一性,通常是指需要确保消费者接收到的消息是没有被其他消费者重复消费的。这通常涉及到分布式环境下的消息传递和处理,可以通过以下几种方式实现:使用消息队列提供的唯一性保证机制:对于Kafka,可以使用消息的唯一ID(例如:消息的offset)。对于RabbitMQ,可
  • 2024-03-25aardio封装库) sunny抓包工具的使用
    前言还有个迭代器,基础语法基本已经说完了,后面想到啥再补充,之后的教程会从以下方面来讲:基础库的使用,比如string、table等基础控件的使用,比如listview、tab等aardio和Python交互,比如给Python写个界面自带的范例程序我写的一些小程序当然,我的理解也是很基础的,特别是在界面设
  • 2024-03-20aardio教程三) 元表、元方法
    前言还有个迭代器,基础语法基本已经说完了,后面想到啥再补充,之后的教程会从以下方面来讲:基础库的使用,比如string、table等基础控件的使用,比如listview、tab等aardio和Python交互,比如给Python写个界面自带的范例程序我写的一些小程序当然,我的理解也是很基础的,特别是在界面设
  • 2023-12-18当指定了一个 messageid 后,发送或插入消息,即使成功,也查询不到此消息
    SDKmessageid仅在发送失败时,可以使用SDK已经构建好的id,不支持自己指定一个自定义的id值。如果传入一个SDK不存在的id会导致消息丢失如果传入一个SDK存在的但不是当前消息的id,会导致原有消息内容发生变更,导致消息错乱。
  • 2023-12-04RabbitMQ避免重复消费
    在Java中,可以使用消息队列来实现消息的异步处理,其中常用的消息队列有RabbitMQ、ActiveMQ、Kafka等。什么是幂等性?幂等性是指无论操作执行多少次,都是得到相同的结果,而不会产生其他副作用。在rabbitMQ中什么是消息重复消费?同一条消息在MQ中被消费多次出现重复消费的原因:生
  • 2023-08-01TDengine连接数满了报错:Connection is not available, request timed out after 30000ms.
    背景使用tdengine时遇到一个情况,应用程序使用连接池将接收到的实时数据插入TD时,会出现获取不到连接的报错.重现起一个模拟程序,发送100条数据到应用程序,应用程序从批量插入改为逐条插入td,重现出报错:org.springframework.jdbc.support.MetaDataAccessException:Could
  • 2023-07-29十九、消息查询
    RocketMQ支持按照下面两种维度(“按照MessageId查询消息”、“按照MessageKey查询消息”)进行消息查询。在RocketMQdashboard中:点击消息,可以选择MessageId和MessageKey查询。按照MessageId查询消息RocketMQ中的MessageId的长度总共有16字节,其中包含了消息存储主机地址(IP地
  • 2023-01-30分布式事务(二):基于可靠消息的分布式事务
    项目使用技术springboot、dubbo、zookeeper、定时任务、消息中间件MQ一、项目结构maven父子工程:父工程:consis子工程:api-service、order、product、messageapi-service
  • 2022-11-03跟炒鸡辣鸡一起学用go写游戏后端
    几个月前,把java分布式游戏后端研究了一遍,仿照现成的架构写了两套游戏出来。但是我的脚步并未停下,现在开始研究如何用Go语言搭建游戏后端。1、设计前后端交互的方式之前的j
  • 2022-09-25pulsar-websocket协议
    WebSocket简介通过Pulsar的WebSocketAPI,用户可以简单便捷地与Pulsar进行交互,WebSocketAPI不依赖于官方客户端库。WebSocket支持使用Java、Go、Python和C++