云计算
分布式 标签描述

说明:在RabbitMQ消息传递过程中,有以下问题: 消息没发到交换机 消息没发到队列 MQ宕机,消息在队列中丢失 消息者接收到消息后,未能正常消费(程序报错),此时消息已在队列中移除 针对以上问题,提供以下解决方案: 消息确认:确认消息是否发送到交换机、队列; 消息持久化:持久化消息,以防MQ宕机造成消息丢失; 消费者消息确认:确认消费者已正确消费消息,才把消息从队列中删除; 消息确认 可以使用RabbitMQ提供的publisherconfirm机制来避免消息发送到MQ过程丢失。具体实现是,publisher-confirm(发送者确定)、publisher-return(发...

  zNRyot8onCGb   14天前   9   0   0 分布式rabbitmqjava

说明:RabbitMQ是一门异步通讯技术,使用异步通讯技术,可解决同步通讯的一些问题。 安装 本文介绍在云服务器上安装RabbitMQ,操作系统是CentOS7,远程连接工具是WindTerm; 第一步:拉取镜像 镜像版本选择,3.8-management dockerpullrabbitmq:3.8-management 我这里显示已经安装过,首次安装会下载一些文件,等下载完成即可; 第二步:运行容器 输入下面命令,运行RabbitMQ容器,设置登录账号为:root,密码:123456 dockerrun\ -eRABBITMQ_DEFAULT_USER=root\ -eRABBITM...

  zNRyot8onCGb   14天前   18   0   0 分布式rabbitmq

说明:在微服务架构开发中,一个请求是通过模块之间的互相通信来完成的,如下面这个场景: 创建两个子模块:订单模块(端口8081)、用户模块(端口8082),两个模块之间没有联系,现在需要查询订单,根据订单中的用户ID,查询该订单对应的用户信息。 (两个模块是独立的) 用户实体类 importlombok.Data; importjava.io.Serializable; /用户/ @Data publicclassUserimplementsSerializable{ /ID/ privateLongid; /用户名/ privateStringusername; /地址/ ...

  zNRyot8onCGb   14天前   29   0   0 分布式springbootjava