2022-08-05 16:42:09

目录引言1消息1.1topic1.2Body1.3tag1.4key1.5延迟级别2生产者高可用2.1客户端保证生产者高可用2.1.1重试机制2.1.2客户端容错2.2Broke...目录引言1 消息1.1 topic1.2 Body1

2022-07-29 18:08:11

目录队列的类型数据结构阻塞队列 BlockingQueue常见的阻塞队列BlockingQueue APIArrayBlockingQueue 源码简解生产者消费者模式延迟队列 DelayQueue队列的类型无限队列(unbo

2022-07-26 11:52:45

目录Springboot整合RockerMQ使用总结消费模式生产者组和消费者组生产者投递消息的三种方式如何保证消息不丢失顺序消息分布式事务Springboot整合RockerMQ1、maven依赖<depen

2022-07-25 10:58:45

目录前言原理简单的实现生产者延迟服务消费者改进点通用的延迟服务生产者负责延迟服务总结前言延迟队列是一个非常有用的工具，我们经常遇到需要使用延迟队列的场景，比如延迟通

2022-07-20 13:52:52

目录前言方法一：用两个通道 + A协程sleep方法二：使用Timer（定时器）方法三：使用context.WithTimeout附：go 实现超时退出总结前言超时，指一个协程A开启另一个协程B，A会阻塞等待B一段指

2022-07-20 12:44:02

目录前言方法一：用两个通道+A协程sleep方法二：使用Timer（定时器）方法三：使用context.WithTimeout附：go实现超时退出总结前言超时，指一个协程A开启另一个协程B，A会...目录前言方法一：

2022-07-15 12:18:25

目录1. 前言1.1 常用函数式编程1.2 Stream操作2. Java响应式编程带有中间处理器的响应式流3. Reactor3.1 Flux & Mono3.2 Flux Mono创建与使用4. WebFluxSpring WebFlux示例

2022-07-15 10:43:29

目录1.前言1.1常用函数式编程1.2Stream操作2.Java响应式编程带有中间处理器的响应式流3.Reactor3.1FluxMono3.2FluxMono创建与使用4.W...目录1. 前言1.1 常用函数式编程1.2

2022-07-03 22:11:09

golang最吸引人的地方可能就是并发了，无论代码的编写上，还是性能上面，golang都有绝对的优势学习一个语言的并发特性，我喜欢实现一个生产者消费者模型，这个模型非常经典，适用于很多

2022-07-02 17:44:31

先贴代码packagemainimport(fmt)//Sendthesequence2,3,4,...tochannel'ch'.funcgenerate(chcha...先贴代码package main import ("fmt") // Send the sequence 2, 3, 4,

2022-07-01 18:50:29

目录一、添加pom.xml依赖二、Pulsar 参数类三、Pulsar 配置类四、不同消费数据类型的监听器五、Pulsar的核心服务类六、Pulsar整合Spring Cloud一、添加pom.xml依赖<parent>

2022-06-30 18:08:08

目录简介原理具体实现消费者消费者生产者消息监听器消息事务测试正常测试异常测试代码调整执行结果总结简介RocketMQ>原理RocketMQ事务消息通过异步确保方式，保证事务的最终

2022-06-16 08:46:26

MemcacheQ 是一个简单的分布式队列服务，它的运行依赖于BerkeleyDB 和 libevent，所以需要先安装BerkeleyDB和libevent,需要的朋友可以参考下一. 安装MemcacheQ 是一个简单的分

2022-06-15 19:36:55

下面小编就为大家带来一篇浅谈生产者消费者模型(Linux系统下的两种实现方法)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧生产者消费者问

2022-06-15 08:34:01

条件变量是利用线程间共享的全局变量进行同步的一种机制，主要包括两个动作：一个线程等待条件变量的条件成立而挂起（此时不再占用cpu）；另一个线程使条件成立（给出条件成立信号）。引

2022-06-13 12:05:23

目录1. 线程通信1.1 互斥锁1.2 线程间全局变量的共享1.3 共享内存间存在竞争问题1.4 使用锁来控制共享资源的访问分析此阶段，我们会发现进程和线程的痛点！！！2. 队列的基本概念总

2022-06-09 13:55:57

目录普通队列阻塞队列发布订阅模式延时队列和优先级队列应用场景Redis不仅可作为缓存服务器，还可以用作消息队列。它的列表类型天生支持用作消息队列。如下图所示：由于Redis的

2022-06-09 11:46:35

目录kafka go库注意例子kafka>kafka go客户端官方目前没有提供，但在github有2个非常流行的库星星较多，网上案例也多 https://github.com/Shopify/saramaconfluent官网提供的库

2022-06-05 21:46:05

目录什么是消息队列消息队列满足哪些特性消息有序性重复消息处理可靠性List实现消息队列LPUSHRPOP实时消费问题重复消费消息可靠性需要注意的是Redission实战添加依赖Java代

2022-06-01 15:47:26

背景项目中的流程监控，有几种节点，需要监控每一个节点是否超时。按传统的做法，肯定是通过定时任务，去扫描然后判断，但是定时任务有缺点：1，数据量大会慢；2，时间不好控制，太短，怕一次处理

2022-05-28 08:37:16

本系列将和大家分享Redis分布式缓存，本章主要简单介绍下Redis中的List类型，以及如何使用Redis解决博客数据分页、生产者消费者模型和发布订阅等问题。Redis List的实现为一个

2022-05-27 18:04:45

目录前言一、RocketMQ 消息模式集群消费模式广播消费模式二、push 和 pull 优缺点Pull方式Push方式三、刷盘策略同步刷盘异步刷盘四、MQ 异常测试MQ消息体消息重复发送消息

2022-05-27 17:57:13

目录一、什么是 MQ二、MQ 的作用1. 流量削峰2. 应用解耦3. 异步处理三、MQ 的缺点四、常见 MQ 分类1. ActiveMQ2. Kafka3. RocketMQ4. RabbitMQ五、MQ 的组成1. 角色2. MQ

2022-05-24 14:08:54

目录协程yield在协程中的用法经典示例生产者-消费者模式（协程）gevent第三方库协程支持经典代码asyncio内置库协程支持关于aiohttp协程协程简单来说就是一个更加轻量级的线程，并

2022-05-23 20:51:07

最近博主在看redis的时候发现了两种redis使用方式，与之前redis作为缓存不同，利用的是redis可设置key的有效时间和redis的BRPOP命令。分布式锁由于目前一些编程语言，如php等，不能