2023年2月1日

Redis 分布式锁

摘要： 先理解线程锁，线程锁 就是锁住线程的锁 分布式锁就是锁住进程的锁 在集群的环境下应该使用锁进程的方式 1 using StackExchange.Redis; 2 using System; 3 using System.Collections.Generic; 4 using System.Lin 阅读全文

posted @ 2023-02-01 16:44 是水饺不是水饺 阅读(74) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 事务(八)

摘要： 1 public void TxProducer() 2 { 3 string queueName = "ORIGN_QUEUE"; 4 using(var connection = RabbitMQHelper.GetConnection("192.168.3.200", 5671)) 5 { 6 阅读全文

posted @ 2023-02-01 01:15 是水饺不是水饺 阅读(13) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 失败重试 (七)

摘要： 主要 代码 消息的 Properties.headers.x-death 属性中查询到消息投递源信息和消息被投递的次数； 1 2 var consumer = new EventingBasicConsumer(channel); 3 consumer.Received += (model, ea) 阅读全文

posted @ 2023-02-01 00:28 是水饺不是水饺 阅读(72) 评论(1) 推荐(0) 编辑

.net core 下使用 RabbitMQ 设置1次消费1条消息 (六)

摘要： 主要设置 设置prefetchCount=1，来告知RabbitMQ，在未收到消费端的消息确认时，不再分发消息，也就确保了当消费端处于忙碌状态时，不再分配任务。 channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false); 1 阅读全文

posted @ 2023-02-01 00:20 是水饺不是水饺 阅读(86) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 消息没有正确路由到队列处理方式错误消息回调 (五)

摘要： 消息回调 1 public void Producer() 2 { 3 string queueName = "RE_QUEUE"; 4 string exchangeName = "RE_EXCHANGE"; 5 using (var connection = RabbitMQHelper.Get 阅读全文

posted @ 2023-02-01 00:14 是水饺不是水饺 阅读(33) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 交换机备份 (四)

摘要： 1 public void BackupMethod() 2 { 3 string queueName = "BACKUP_QUEUE"; 4 string exchangeName = "BACKUP_EXCHANGE"; 5 string backupQueue = "BACKUP_QUEUE_ 阅读全文

posted @ 2023-02-01 00:05 是水饺不是水饺 阅读(23) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 延迟队列 (三)

摘要： 延迟队列，跟死信队列差不多 队列设置及参数： 参数名 类型 作用x-message-tti(Time-To-Live) int，毫秒 对消息设置预期的时间，过期将被丢弃x-max-length int 限制队列最大长度,个数，新增后删除最早的x-expires int，毫秒 队列没有访问超时时，自动 阅读全文

posted @ 2023-02-01 00:01 是水饺不是水饺 阅读(106) 评论(0) 推荐(0) 编辑