美文网首页
生产者消费者构建

生产者消费者构建

作者: Change_6556 | 来源:发表于2019-10-14 18:23 被阅读0次

    生产者
    1.创建connectfactory对象

    setHost("192.222.21")
    setPort
    setVirtureHost("/")
    创建connection连接
    3.connection创建channel
    4.通过channel发送数据
    channel.basicPublic(exchange,routingket,props ,body) ,props body消息组成部分
    5.关闭相应的连接

    消费端
    前三点可以复用
    4.声明创建一个队列
    channel.queueDeclare(queuename,dura是否持久化,是否独占exclusive,自动删除脱离exchangeautodelete ,描述auguments)
    独占保证顺序消费 负载均衡不能保证消费进度,

    相关文章

      网友评论

          本文标题:生产者消费者构建

          本文链接:https://www.haomeiwen.com/subject/uixdmctx.html