Skip To Main Content
String queueName on Muck Rack

String queueName

As seen in: CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile
Back to String queueName’s profile

Articles by String queueName

仿 RabbitMQ 消息队列6（实战项目）

|
By boolean autoDelete, String queueName, binding.setQueue Name, binding.setExchange Name
| CSDN
最新推荐文章于 2025-02-23 14:37:51 发布 小高不明 最新推荐文章于 2025-02-23 14:37:51 发布 阅读量1.2k 收藏 25 点赞数 15 文章标签： rabbitmq 分布式 spring 后端 java 版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。 ⼗. 虚拟主机设计 创建 VirtualHost 创建mqserver.VirtualHost 在 RabbitMQ 中, 虚拟主机是可以随意创建/删除的. 咱们此处为了实现简单, 并没有实现虚拟主机的管理.
Open in Who Shared Issue with article?

.NET6中使用RabbitMQ详尽指南-CSDN博客

|
By String username, String queueName, String routingKey, using Microsoft.Extensions.Logging
| CSDN
解释： RabbitMQ 是一个流行的开源消息队列系统，广泛用于实现异步通信、解耦组件、负载均衡等场景。在本篇博客中，我们将详细介绍如何在 .NET 6 中使用 RabbitMQ，包括生产者和消费者的实现，以及如何通过依赖注入来管理它们。 一、创建 .NET 6 应用 首先，确保你已经安装了 .NET 6 SDK。可以使用命令行工具创建一个新的 .NET 控制台应用： dotnet new console -n RabbitMQDemo cd RabbitMQDemo 接着，你需要安装 RabbitMQ 的客户端库，通过 NuGet 包管理器来安装 RabbitMQ.Client： dotnet add package RabbitMQ.Client; //这里我们选择 6.4.0 版本 dotnet add package Masuit.Tools.Core; //这个为一个 二、配置 RabbitMQ 接下来，我们需要定义连接 RabbitMQ 所需的配置选项。通常我们会将这些配置选项存储在一个类中。以下是配置类(RabbitMQServiceOptions)的实现： ///...
Open in Who Shared Issue with article?

RabbitMQ实现保证消息可靠性-CSDN博客

|
By String queueName, Timeout Exception
| CSDN
本篇文章不再介绍RabbitMQ具体实现原理，直接介绍如何保证消息的可靠性问题。所谓可靠性，指消息不重不漏。 生产者消费者模型 生产者-消费者模型用于描述两类进程（生产者和消费者）之间的数据交互。可以被认为是独立的服务，生产者负责生成数据，消费者负责处理这些数据。在分布式系统中，队列在其中扮演了消息（数据）传递的功能。 关于消息队列的作用，一般解读为： 解耦：生产者和消费者独立运作，无需知道对方的运行状态。 异步：并非实时，生产者不必关注消费端的消费情况。 削峰：限制流量，防止消费者过载。 消息丢失 这其实不难理解，就像生活中下单-快递-签收的过程。这个过程和上边的生产者-消费者模型恰有异曲同工之妙。 这个过程中， 下单用户（生产者） 快递小哥（队列） 签收人（消费者） 快件（消息） 如果包裹被粗略的认为是一条消息，那么快件在邮寄过程中丢失了，就是消息丢失。快件从发货到签收，我们不用去关心中间发生了什么。但是要是没收到货，那得给我个理由。 如何排查？ 就上边的快件丢失问题，怎么知道快递为何没有收到？很简单，一段一段的排查： 商家是否有发货？ 快递公司是否揽收？...
Open in Who Shared Issue with article?

2024.2.23 模拟实现 RabbitMQ -- 实现消费消息逻辑

|
By import lombok.Data, boolean autoAck, String queueName
| CSDN
目录 引言 引言 函数式接口 Lambda 表达式的本质是匿名函数 Java 函数无法脱离类而存在，所以 Java 通过引入函数式接口以支持 Lambda 表达式 特性： 函数式接口为一个 interface 类 该类中有且仅有一个方法 该类需加上 @FunctionalInterface 注解 注意： 上述三点其实就是 Lambda 的本质，即底层实现 消费者订阅消息 实现思路 1、让 broker server 把有哪些消费者管理好 消费者调用 basicConsume 方法就是订阅某个指定队列的消息 注意： 消费者是以队列为纬度订阅的 一个队列可以有多个消费者 约定 消费者之间按照 轮询 的方式进行消费 代码编写： 定义一个 ConsumerEnv 类，用来描述一个消费者 该类中也会包含一些消费者消费过程中用到的数据 import lombok.Data; /* * 表示一个消费者(完整的执行环境) * */ @Data public class ConsumerEnv { private String consumerTag; private String...
Open in Who Shared Issue with article?

.Net 6 下WorkerService+RabbitMq实现消息的异步发布订阅

|
By String exchangeName, String queueName, Public RabbitMqprovider, Public Imodel GetChannel
| CSDN
近期项目里有需要用到RabbitMq实现一些业务，学习整理之后在此记录一下，如有问题或者不对的地方，欢迎留言指正。 一、首先创建连接工厂 public class RabbitMQProvider { private readonly string _ipAddress; private readonly int? _port; private readonly string _username; private readonly string _password; public RabbitMQProvider() { _ipAddress = ConfigurationHelper.GetKey("RabbitMQIPAddress") ?? throw new ArgumentException("IP地址未配置！"); _username = ConfigurationHelper.GetKey("RabbitMQUserName") ??
Open in Who Shared Issue with article?

根据源码，模拟实现 RabbitMQ - 虚拟主机 + Consume设计 (7)

|
By boolean autoAck, String queueName, message.getBasic Properties
| CSDN
目录 1.1、承接问题 前面已经实现了虚拟主机大部分功能以及转发规则的判定，也就是说，现在消息已经可以通过 转换机 根据对应的转发规则发送给对应的 队列 了. 那么接下来要解决的问题就是，消费者该如何订阅消息（队列），如何把消息推送给消费者，以及消费者如何描述自己怎么执行任务~ 1.2、具体实现 消费者是以队列为维度订阅消息的，并且一个队列可以被多个消费者订阅，那么一旦队列中有消息，这个消息到底因该给谁呢？此处就约定，消费者之间按照 “轮询” 的方式来进行消费.
Open in Who Shared Issue with article?
Show More