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:32

目录1offset的默认维护位置1.1消费offset案例2自动提交offset3手动提交offset3.1原理3.2代码示例4指定offset消费5指定时间消费6漏消费和重复消费分...目录1 offset的默认维

2023-03-07 10:36:18

目录kafka-console-consumer.sh解读消息消费从开始位置消费显示key消费总结kafka-console-consumer.sh解读kafka-console-consumer.s...目录kafka-console-consumer.sh解读

2023-03-07 10:06:13

目录kafka消费者kafka-console-consumer接收不到数据问题解决关于kafka-console-consumer.sh消费者的一些思考(人物设定初步了解kafka的我)kafka-...目录kafka消费者kafka-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-16 09:05:07

IT之家 2 月 16 日消息，根据 CNBC 报道，高盛已经放弃扩张消费信贷业务，砍掉除了 Apple Card 之外的所有消费者信用卡业务。IT之家从报道中了解到，高盛的消费者部门出现了严重的

2023-02-14 09:36:57

目录一、概述二、集群消费三、广播消费一、概述RocketMQ主要提供了两种消费模式：集群消费以及广播消费。我们只需要在定义消费者的时候通过setMessageModel(MessageModel.XX.

2023-02-14 09:07:15

目录一、什么是延时消息二、延时消息等级三、延时消息使用场景四、延时消息示例五、延时消息实现原理一、什么是延时消息当消息写入到Broker后，不能立刻被消费者消费，需要等待

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-08 14:04:38

IT之家 2 月 8 日消息，据北京市消费者协会网站消息，北京电影协会和北京市消费者协会联合发布《关于营造良好电影市场环境的倡议书》，倡议严厉打击违背消费者意愿强制租售商品等

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-22 06:05:13

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

2023-01-21 09:05:16

IT之家 1 月 21 日消息，美联储（The Federal Reserve）已对高盛展开调查，以确定其消费者信贷部门（含 Apple Card）是否制定和部署了完善的消费者保护措施。高盛于 1 月 13 日披露的文

2023-01-12 14:04:51

IT之家 1 月 12 日消息，针对“爱奇艺 App 限制投屏加收费用”的做法，上海市消保委表示，平台在 App 内限制消费者投屏的做法不合理，想用这种方法加收费用更不厚道。上海市消保委

2023-01-10 11:38:18

RabbitMQWorkQueue工作队列工作队列(又称任务队列)的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。相反我们安排任务在之后执行。我们把任务封装为消息并将其

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-23 10:59:51

目录goroutine 泄漏和避免泄漏的最佳实践什么是goroutine泄漏？原因分析伪代码有什么方法可以解决这个问题？goroutine>Go的奇妙之处在于，我们可以使用goroutines和channel轻松地