如何在docker compose中使用主机名连接到RabbitMQ流插件

试试这样的方法:

using System.Text;
using System.Net;
using Microsoft.Extensions.Logging;
using RabbitMQ.Stream.Client;
using RabbitMQ.Stream.Client.Reliable;

class Program
{
    public static async Task Main(string[] args)
    {         
        string dnsName = "rabbitmq"; // Use the name of the RabbitMQ service.
        int port = 5552;
        try
        {
            // Resolve DNS name into IP address.
            IPAddress[] addresses = Dns.GetHostAddresses(dnsName);
            // Add port to get a dull endpoint.
            IPEndPoint endPoint = new IPEndPoint(addresses[0], port);
            Console.WriteLine("Connect to RabbitMQ at {0}.", endPoint);
            var streamSystem = await StreamSystem.Create(
                new StreamSystemConfig()
                {
                    UserName = "guest",
                    Password = "guest",
                    Endpoints = new List<EndPoint>() {endPoint}
                }
            ).ConfigureAwait(false);
        }
        catch (Exception e)
        {
            Console.WriteLine("An error occurred: " + e.Message);
        }
    }
}

当您构建并运行时,您应该会看到打印的消息如下:

Connect to RabbitMQ at 192.168.224.2:5552.

在Docker Compose网络中,RabbitMQ服务正在DNS名称的容器上运行 rabbitmq 这个 GetHostAddresses() 方法将此DNS名称动态转换为IP地址。无需硬编码任何地址。