首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

#mq

使用C#封装一个MQ测试工具

软件架构师Michael

这个工具可以用于测试常见的MQ操作,例如发送消息、接收消息、查看队列状态等。我们将使用.NET的System.Messaging命名空间来操作本地或远程的消息队...

6410

MQ消息队列学习入门

GeekLiHua

腾讯 | 业务安全工程师 (已认证)

想象一下,在一个繁忙的市场里,每个摊位都是一个独立的服务或应用程序。这些摊位之间需要频繁地交换商品和信息,但是如果他们没有一个有效的沟通系统,市场将会变得一片混...

8810

MQ如何实现,消息幂等(MQ真的不能再背锅了)?(第33讲)

架构师之路

如《MQ如何实现,消息必达?(第32讲)》所述,MQ能解除发布订阅者之间的耦合,它将消息投递解耦成上下两个半场:

10000

MQ如何实现,消息必达到?(第32讲)

架构师之路

蓝色MQ核心集群由MQ-server,zk,db,管理后台web等一系列子系统组成。

8810

RocketMQ(十一):事务消息如何满足分布式一致性?

菜菜的后端私房菜

在分布式系统中由于相关联的多个服务所在的数据库互相隔离,数据库无法使用本地事务来保证数据的一致性,因此需要使用分布式事务来保证数据的一致性

29030

RocketMQ(十):如何保证消息严格有序?

菜菜的后端私房菜

如果不使用保证顺序的手段,由于多队列、网络等因素可能会导致先处理支付订单的消息再处理创建订单的消息,这样就会导致处理失败

16520

如何解决MQ消息积压问题?

用户11397231

在分布式系统中,消息队列(MQ)是不可或缺的组件,它负责在不同服务之间异步传递消息。然而,消息积压问题是一个常见的挑战,它可能导致系统性能下降甚至服务中断。本文...

13410

工作中这样用MQ,很香!

苏三说技术

对很多小伙伴来说,刚接触MQ时,可能觉得它只是个“传话工具”,但用着用着,你会发现它简直是系统的“润滑剂”。

11410

通过模拟发送mq消息来测试实现-依据支付凭证不能重复入账

oktokeep

1.依据MQ消息的json串转换为md5记录,作为收银台表的唯一约束。如果支付状态发生变化,则payMd5会跟随着变化。

7410

排查MQ消息发送和接收

oktokeep

Caused by: com.alibaba.fastjson.JSONException: can not cast to JSONObject. at c...

7210

探索 RocketMQ:企业级消息中间件的选择与应用

用户7954602

RocketMQ 是一个高性能、高可靠、可扩展的分布式消息中间件,它是由阿里巴巴开发并贡献给 Apache 软件基金会的一个开源项目。RocketMQ 主要用于...

10810

RibbitMQ学习笔记之MQ发布确认

默 语

生产者将信道设置成 confirm 模式,一旦信道进入 confirm 模式,**所有在该信道上面发布的消息都将会被指派一个唯一的 ID( 从 1 开始),**...

6410

RibbitMQ学习笔记之MQ练习

默 语

为了保证消息在发送过程中不丢失,rabbitmq 引入消息应答机制,消息应答就是:消费者在接收到消息并且处理该消息之后,告诉 rabbitmq 它已经处理了,r...

6300

支付回调消息的分布式锁设计

oktokeep

业务系统接收支付系统发送的MQ消息,然后推动业务逻辑及订单状态的处理。 如果非正常情况下,支付系统接收到多次第三方支付系统的多次回调,导致会发送多次MQ消息。 ...

12710

支付回调MQ消息的幂等处理及MD5字符串es中的使用及支付宝预授权完成

oktokeep

1.幂等的处理,根据对象的转json 转md5作为key,退款的处理 控制发送端?业务上比较难控制。支付异步通知,退款有同步通知(同步通知构建了异步通知)和...

8410

业务消息的前后不一致问题

oktokeep

消息的前后不一致问题。 1.A系统更新请求参数,记录请求来源。然后再远程调用B系统的接口来处理。在B系统处理成功之后,会发送MQ消息来反馈业务逻辑。 A系统在接...

9710

RocketMQ(四):消费前如何拉取消息?(长轮询机制)

菜菜的后端私房菜

上篇文章从Broker接收消息开始,到消息持久化到各种文件结束,分析完消息在Broker持久化的流程与原理

61550

【干货】看看我司消息队列用啥,全网最接地气pulsar教程(含业务解耦demo源码)

JavaDog程序狗

通过简单代码demo进行讲解,pulsar在java中如何使用?如何通过pulsar进行异步解耦?......等

22110
领券