相关推荐recommended
生产者
  • RabbitMQ反序列化失败:Failed to convert message
    03-2024
    RabbitMQ反序列化失败:Failed to convert message

    🎈 1 参考文档 RabbitMQ消费消息坑:failed to convert serialized Message content | jiuchengi-cnblogs 🔍2 问...

  • 如何将Springboot项目升级成Springcloud项目(有图详解)
    03-2024
    如何将Springboot项目升级成Springcloud项目(有图详解)

    本文以nacos为例 分为以下几个步骤1. 下载nacos软件2. pom文件配置3. application.yml文件配置4. 代码调用5. 效果展示 一 . 下载nacos软件 1.1 下载nacos-server-2.2.0-BET...

  • RabbitMQ-如何保证消息不丢失
    03-2024
    RabbitMQ-如何保证消息不丢失

    RabbitMQ常用于 异步发送,mysql,redis,es之间的数据同步 ,分布式事务,削峰填谷等..... 在微服务中,rabbitmq是我们经常用到的消息中间件。它能够异步的在各个业务之中进行消息的接受和发送,那么如何保证rabbi...

  • 【Spring云原生系列】Spring RabbitMQ:异步处理机制的基础--消息队列 原理讲解+使用教程
    03-2024
    【Spring云原生系列】Spring RabbitMQ:异步处理机制的基础--消息队列 原理讲解+

    🎉🎉欢迎光临,终于等到你啦🎉🎉 🏅我是苏泽,一位对技术充满热情的探索者和分享者。🚀&#x...

  • SpringCloud-基于SpringAMQP实现消息队列
    03-2024
    SpringCloud-基于SpringAMQP实现消息队列

    一、Spring AMQP介绍 Spring AMQP作为Spring框架的一部分,是一套用于支持高级消息队列协议(AMQP)的工具。AMQP是一种强大的消息协议,旨在支持可靠的消息传递,特别适用于构建分布式系统。Spring AMQP构建...

  • 【kafka】使用docker启动kafka
    03-0424
    【kafka】使用docker启动kafka

    1.环境准备 docker拉取zookeeper镜像 docker pull zookeeper:3.4.14 创建zookeeper容器,默认端口号为2181 docker run -d --name zookeeper -p 2181:...

  • kafka日志文件详解及生产常见问题总结
    03-0424
    kafka日志文件详解及生产常见问题总结

    一、kafka的log日志梳理 日志文件是kafka根目录下的configserver.properties文件,配置log.dirs=usrlocalkafkakafka-logs,kafka一部分数据包含当前Broker节点的...

  • SpringAMQP开启“可靠性”机制
    02-2424
    SpringAMQP开启“可靠性”机制

    前言 上一篇介绍了如何在 《SpringBoot 中集成和使用消息队列》,看过这一篇就基本上可以在SpringBoot中使用消息队列了,但是消息队列他归根结底是一个客户端服务器模式的中间件,面对复杂的网络环境和分布式使用环境,难免会出现各种...

  • Spring RabbitMQ那些事(3-消息可靠传输和订阅)
    02-2024
    Spring RabbitMQ那些事(3-消息可靠传输和订阅)

    目录一、序言二、生产者确保消息发送成功1、为什么需要Publisher Confirms2、哪些消息会被确认处理成功三、消费者保证消息被处理四、Spring RabbitMQ支持代码示例1、 application.yml2、Rab...

  • RabbitMQ之消息的可靠性传递
    02-0624
    RabbitMQ之消息的可靠性传递

    系列文章目录提示:这里可以添加系列文章的所有文章的目录,目录需要自己手动添加RabbitMQ之消息的可靠性传递提示:写完文章后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录系列文章目录前言一、消息的可靠性传递的...

  • Kafka-多线程消费及分区设置
    02-0624
    Kafka-多线程消费及分区设置

    目录一、Kafka是什么?消息系统:Publishsubscribe(发布订阅者)模式相关术语二、初步使用1.yml文件配置2.生产者类3.消费者类4.发送消息三、减少分区数量1.停止业务服务进程2.停止kafka服务进程3...

  • 微服务同时接入多个Kafka
    02-0624
    微服务同时接入多个Kafka

    最近在做微服务的迁移改造工作,其中有一个服务需要订阅多个Kafka,如果使用spring kafka自动配置的话只能配置一个Kafka,不符合需求,该文总结了如何配置多个Kafka,希望对您有帮助。 文章目录准备工作最小化配置K...

  • kafka消费相关问题(GPT回答版本)
    02-0624
    kafka消费相关问题(GPT回答版本)

    kafka消费相关问题(GPT回答版本) 在Java中,要避免重复消费Kafka消息,可以使用以下方法 1. 使用消费者组: 在设置Kafka消费者时,可以指定一个消费者组。一个消费者组中可以有多个消费者实例,每个实例只会消费到消息的其中一...

  • SpringCloud-生产者和消费者
    02-0624
    SpringCloud-生产者和消费者

    一、生产者和消费者的定义 在 Spring Cloud 中,术语 "生产者" 和 "消费者" 用于描述微服务架构中的两种基本角色。 角色定义生产者Provider生产者是提供具体服务或功能的模块。它将...

  • Kafka(七)可靠性
    02-0524
    Kafka(七)可靠性

    目录1 可靠的数据传递1.1 Kafka的可靠性保证1.2 复制1.3 Broker配置1.3.1 复制系数1.3.2 broker的位置分布1.3.3 不彻底的首领选举1.3.4 最少同步副本1.3.5 保持副本同步1.3.6 持久化...

  • RabbitMQ----生产者可靠性
    02-0524
    RabbitMQ----生产者可靠性

    RabbitMQ----生产者可靠性 生产者可靠性主要分为两个方面: 生产者重连生产者确认 一、生产者重连         有的时候由于网络波动,可能会出现客户端连接MO失败的情况。通过配置我们可以开启连接失败后的重连机制: spring:...

  • kafka(二)——常用命令
    02-0224
    kafka(二)——常用命令

    常用脚本 kafka执行脚本默认在安装的bin目录下,本文中示例均基于bin目录执行。 #查询topic状态,新建,删除,扩容kafka-topics.sh #查看,修改kafka配置kafka-configs.sh #配置,查看kafka...

  • 【Java系列】多线程案例学习——基于阻塞队列实现生产者消费者模型
    01-2524
    【Java系列】多线程案例学习——基于阻塞队列实现生产者消费者模型

    个人主页:兜里有颗棉花糖欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 兜里有颗棉花糖 原创收录于专栏【Java系列专栏】【JaveEE学习专栏】本专栏旨在分享学习JavaEE的一点学习心得,欢...

  • 第二章 Spring Boot 整合 Kafka消息队列 生产者
    01-2524
    第二章 Spring Boot 整合 Kafka消息队列 生产者

    系列文章目录 第一章 Kafka 配置部署及SASL_PLAINTEXT安全认证 第二章  Spring Boot 整合 Kafka消息队列 生产者 第三章  Spring Boot 整合 Kafka消息队列 消息者 前言       ...

  • RabbitMQ的基本使用,进行实例案例的消息队列
    01-2324
    RabbitMQ的基本使用,进行实例案例的消息队列

    目录 一、介绍 1. 概述 2. 作用 3. 工作原理 二、RabbitMQ安装部署 1. 安装 2. 部署 3. 增加用户 三、实现案例 1. 项目创建 2. 项目配置 3. 生产者代码 4. 消费者代码 四、测试 每篇一获一、介绍...