zoukankan      html  css  js  c++  java
  • RabbitMq 应用

    RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。它可以用于大型软件系统各个模块之间的高效通信,支持高并发,支持可扩展。

    前提是你的RabbitMq服务已搭建好,制作一个winform窗体如图

    入队列(生产者):

    ServerAddress = this.ServerAddress.Text.Trim(),
    VirtualHost = this.VirtualHost.Text.Trim(),
    UserName = this.UserName.Text.Trim(),
    Password = this.Password.Text.Trim(),
    Exchange = this.Exchange.Text.Trim(),
    ExchangeType = "direct",
    RoutingKey = this.RoutingKey.Text.Trim()
    };

    RabbitProducer rp = new RabbitProducer(rpc);
    rp.ProduceMessage("1", this.QueueName.Text.Trim());
    rpc = null;
    this.label8.Text = "发送" + this.QueueName.Text.Trim() + "队列数据成功";

    出队列(消费者):

    RabbitConsumerConfig rcc = new RabbitConsumerConfig()
    {
    ServerAddress = this.ServerAddress.Text.Trim(),
    VirtualHost = this.VirtualHost.Text.Trim(),
    UserName = this.UserName.Text.Trim(),
    Password = this.Password.Text.Trim()
    };
    RabbitConsumer rc = new RabbitConsumer(rcc);
    rc.ConsumeMessage(GetQueue, this.QueueName.Text.Trim());

    这只是模仿了生产者和消费者,如果产生错误队列该怎么办?欲知后事如何,请听下次分享。。。。

  • 相关阅读:
    SWFObject2.0
    年轻人买房的问题
    百度知道的php爬虫
    PHP解决多进程同时读写一个…
    php快速定位多维数组的深度
    不要用充实的借口去浪费时间
    php跨服务器信息获取之cURL
    为你的生命多积累一些厚度
    看完一定让你很受益!
    phpQuery轻松采集网页内容
  • 原文地址:https://www.cnblogs.com/viaiu/p/4832811.html
Copyright © 2011-2022 走看看