RabbitMQ 教程远程数据交互

Posted 2020-10-08

回顾前面，我们进行了RabbitMQ的环境搭建，配置，还有本地代码的简单交互。现在我们来进行远程数据交互，就是说，我们的RabbitMQ.Server和RabbitMQ.Client可以不在同一个服务器，也能进行数据传输。

一、远程账号配置（参考第一章配置 admin配置）

配置的账号密码，就是用于我们远程服务访问。

 

二、RabbitMQ.Server 写入代码

static void Main(string[] args)
{
    for (int i = 0; i < 50; i++)
    {
        Task.Run(async () =>
        {
            await CreateProdcut();
        });
    }
    Console.ReadLine();
}

private static ConnectionFactory factory = new ConnectionFactory() { HostName = "116.28.8.166", UserName = "admin", Password = "********", VirtualHost = "/" };
private static Task CreateProdcut()
{
    return Task.Factory.StartNew(() =>
    {
         using (var connection = factory.CreateConnection())
         {
             using (var channel = connection.CreateModel())
             {
                 string guid = Guid.NewGuid().ToString();
                 var body = Encoding.UTF8.GetBytes(Guid.NewGuid().ToString());
                 channel.QueueDeclare("AllenLeeQueue", false, false, false, null);
                 channel.BasicPublish("", "AllenLeeQueue", null, body);

                 Console.WriteLine("[Set Msg To AllenLeeQueue] " + guid);
              }
          }
    });
}

 

三、RabbitMQ.Client 写入代码

private static ConnectionFactory factory = new ConnectionFactory() { HostName = "116.28.8.166", UserName = "admin", Password = "********", VirtualHost = "/" };
static void Main(string[] args)
{
    factory.AutomaticRecoveryEnabled = true;//设置端口后自动恢复连接属性即可
    using (var connection = factory.CreateConnection())
    {
        using (var channel = connection.CreateModel())
        {
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [Get Msg from AllenLeeQueue] {0}", message);
            };

            channel.BasicConsume(queue: "AllenLeeQueue", noAck: true, consumer: consumer);
            Console.ReadLine();
        }
    }
}

四、运行RabbitMQ.Server和RabbitMQ.Client

 

我们可以看到，我们远程进行了调用，RabbitMQ.Server发送出来的数据，可以在RabbitMQ.Client进行接收，至此我们的远程访问已经成功。这样后续我们就可以在任意的地方，通过RabbitMQ对服务器的数据进行访问获取，

这为我拉后续的并发打下基础。后续我们就会深入到大数据并发的场景，一步步慢慢由浅入深。