2023-03-11 09:12:17

目录正文准备工作创建 SpringBoot 项目添加 Maven 依赖编写消息生产者编写消息消费者测试总结正文推荐一个基于SpringBoot开发的全平台数据(数据库管理工具)功能比较完善，建

2023-03-10 15:05:51

目录正文步骤一：添加依赖项步骤二：配置Kafka步骤三：创建一个生产者步骤四：创建一个消费者正文本教程将介绍如何在SpringBoot应用程序中使用Kafka。Kafka是一个分布式的发布...目

2023-03-10 14:35:12

目录正文准备工作创建SpringBoot项目添加Maven依赖编写消息生产者编写消息消费者测试总结正文推荐一个基于SpringBoot开发的全平台数据(数据库管理工具)功能比较完善，建议下

2023-03-07 11:36:34

目录前言基于Java的API同步发送异步发送原理主线程拦截器序列化器分区器RecordAccumulatorSender线程影响Sender线程唤醒的条件开始发送ACKS总结前言前面两章我们花费了很长

2023-02-28 15:48:21

目录前言BlockingCollection简单介绍起手式接下来进入实际使用场景场景一: 生产者=> 消费者场景二: 实现队列FIFO(先进先出),LIFO(先进后出)前言如果你想玩转C#>BlockingCol

2023-02-28 12:06:19

目录前言BlockingCollection简单介绍起手式接下来进入实际使用场景场景一:生产者=消费者场景二:实现队列FIFO(先进先出),LIFO(先进后出)前言如果你想玩转C#里面多线程，...目

2023-02-27 08:59:34

目录直奔主题代码解释对比解释看效果注释掉q.task_done()和q.join()仅注释掉q.task_done()**总结最后直奔主题tase_done()的作用：只有消费者把队列所有的数据处理完毕，queue.j

2023-02-23 10:37:20

目录一、Docker拉取镜像并启动RabbitMQ二、HelloWorld（一）依赖导入（二）消息生产者（三）消息消费者三、实现轮训分发消息（一）抽取工具类（二）启动两个工作线程（三）启动发送线程四...目录一

2023-02-20 09:05:54

目录1、正常dubbo调用流程2、如果想在不引用他人jar包的情况下如何调用呢1.获取泛化对象2.泛化调用入参处理3、总结1、正常dubbo调用流程引入dubbo依赖引入他人提供的clinet

2023-02-14 08:36:57

目录一、概述二、Tag过滤三、根据自定义属性进行过滤(SQL过滤)一、概述RocketMQ的消费者可以根据Tag进行消息过滤，也支持自定义属性过滤。消息过滤目前是在Broker端实现的，优

2023-02-13 12:06:35

目录一、RocketMQ事务消息概要二、RocketMQ事务消息使用案例(1)、定义消息监听器(2)、定义消息生产者(3)、定义消息消费者(4)、观察生产者控制台输出(5)、观察消费者控制台

2023-02-13 11:36:11

目录一、什么是消费幂等二、消息重复的场景分析三、如何实现消费幂等一、什么是消费幂等幂等：如果有一个操作，多次执行与一次执行所产生的影响是相同的，我们就称这个操作是幂等

2023-02-09 12:20:46

目录如何在redis中防止消息丢失前言同步的事务——停止等待同步的事务——连续ARQ异步的事务——回调机制消息的幂等处理如何在redis中防止

2023-02-08 09:07:34

目录如何在redis中防止消息丢失前言同步的事务停止等待同步的事务连续ARQ异步的事务回调机制消息的幂等处理如何在redis中防止消息丢失前言在项目中，由于网络问题，我们很难保

2023-02-03 09:47:52

目录1、Disruptor简介2、Disruptor概念3、springboot+disruptor实例4、小结Disruptor是一个高性能队列，常见的还有kafka、rabbitmq等，下面体验一下~1、Disruptor简介Disruptor

2023-02-02 16:37:25

目录1、Disruptor简介2、Disruptor概念3、springboot+disruptor实例4、小结Disruptor是一个高性能队列，常见的还有kafka、rabbitmq等，下面体验一...目录1、Disruptor简介2、Di

2023-01-29 08:47:05

目录线程停止的原理如何正确停止线程在普通情况下停止线程在阻塞情况下停止线程线程在每次迭代后都阻塞停止线程的最佳实践错误停止的方法被弃用的stop,suspend和resume方法

2023-01-22 06:05:13

目录1.概述1.1.数据丢失的原因1.2.如何防止数据丢失2.手动应答3.消息确认机制3.1.AMQP事务3.2.confirm1.概述1.1.数据丢失的原因在消息中有三种可能性造成数据丢失：消费者消

2023-01-06 11:07:25

之前写爬虫程序的时候，采用生产者和消费者的模式，利用Queue作为生产者进程和消费者进程之间的同步队列。执行程序时，总是秒退，加了断点也无法中断，加打印也无法输出，我知道肯定是

2022-12-28 12:08:17

目录SpringCloudStream配置Stream配置Kafka绑定器配置总结SpringCloudStream配置以下配置摘自《SpringCloud微服务实战》，配置主要包括两大部分：Stre...目录SprpythoningCloud

2022-12-28 12:07:34

目录一、前言二、影响因素2.1Kafka服务端2.2生产者端2.3消费者端2.4其他因素总结一、前言本文仅针对Kafka来聊消息分区数相关的话题。SpringCloudStream中的消...目录一、前

2022-12-27 17:08:09

目录线程同步的概念同步代码块同步方法线程组线程组的相关方法线程组对象的基本应用线程间的通信线程通信简单应用线程同步的概念由于同一个进程的多个线程共享同一块存储空

2022-12-27 17:08:06

RocketMQ也允许我们像mysql一样发送具有事务特征的消息MQ的事务流程(本地代码正常执行)MQ的消息补偿过程(当本地代码执行失败时)MQ消息的三种状态提交状态：允许进入队列，此消

2022-12-27 15:38:35

目录1、同步消息2、异步消息3、单向消息1、同步消息即时性较强，重要的消息，且必须有回执的消息，例如短信，通知（转账成功）生产者：publicclassProducer{publics...目录1、同步消息2、

2022-12-21 10:38:35

目录1.Feign传统方式的不足2.动态Feign2.1.服务生产者2.2.动态Feign2.3.服务消费者3.总结1.Feign传统方式的不足①.在微服务架构中,当我们使用Feign传统方式进行服务...目录