RabbitMQ 教程远程数据交互

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RabbitMQ 教程远程数据交互相关的知识,希望对你有一定的参考价值。

回顾前面,我们进行了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对服务器的数据进行访问获取,

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

 

以上是关于RabbitMQ 教程远程数据交互的主要内容,如果未能解决你的问题,请参考以下文章

springboot | Rabbitmq 实现RPC方式 远程同步调用

springboot | Rabbitmq 实现RPC方式 远程同步调用

RabbitMQ学习 (远程过程调用(RPC))

RabbitMq入门以及使用教程

rabbitmq - 不会获取队列中的所有消息

RabbitMQ超详细安装教程(Linux)