zoukankan      html  css  js  c++  java
  • 2019年7月第一周总结-RabbitMQ总结

    这一周主要是对RabbitMQ做了一下学习。

    快速阅读

    RabbitMq的介绍以及环境安装配置,以及RabbitMq的六种应用 。单生产者和消费者,

    单生产者多消费者,消息的发布订阅,消息类型Echange中的Direct,Topic.以及RPC调用

    介绍

    RabbitMQ做为一个消息中间件,用于进程间的通信

    常被用在异步处理,应用解藕,流量消峰等业务场景。

    环境配置

    RabbitMq是用Erlang开发的,所以安装之前要先安装Erlang

    服务端需要安装RabbitMq-server

    vs开发的话,需要通过nuget下载RabbitMQ.client ,

    应用

    单生产者和消费者

    生产者和消费者通过共用一个队列名称,两者之间传输的消息以字节数组存放

    消费者在接收事件中处理接收到的消息 。

    单生产者多消费者

    一个生产者生产的任务 ,多个消费者来消费。

    生产者指定队列名称queue和routingkey,

    消费者创建EventingBasicConsumer。通过queue名称以及设置BasicQos来设置每次取一条消息。

    消息的发布订阅模式

    生产者把消息广播出去,所有的消费者都可以同时接收到消息 。

    两端都声明消息交换的类型是fanout。 消息头中设置消息持久化为true

    消费者创建EventingBasicConsumer 在接收者事件是处理消息 。并且设置basecack

    消息类型Echange中的Direct

    生产者发送的消息 以routingkey进行分组,消费者以routingkey进行不同的接民,

    消费者输入不同的routingkey接收不同的消息。

    消息类型Echange中的Topic

    和Direct消息类型类似,只是加了类型正则表达式的通配符, "*"号代表任意一个单词

    "#"号代表0个或多个单词

    RabbitMq的rpc调用

    生产者和消费者都有一个接收事件 ,生产者先接收消费者发送过来的请求,然后根据请求的消息

    获得相应的结果再加上消息头上标识的消息id和回调队列返回给生产者队列 。

    生产者的接收事件 中处理发送请求的消息的返回值 。

    友情提示

    ​ 我对我的文章负责,发现好多网上的文章 没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题。可以直接在公众号《爱码农爱生活 》留言。必定会再次复查原因。让每一篇 文章的流程都能顺利实现。

  • 相关阅读:
    基于接口(工厂模式)三层架构的引用和访问流程
    数据库访问类小结
    是毁灭还是重生——从浏览器大战看未来软件发展
    Func,Action的介绍及其用法
    IIS发布程序后,出现“服务器应用程序不可用”的错误
    泛型委托 Action<T>和Func<T,TResult>
    IIS发布程序后,出现“服务器应用程序不可用”的错误
    利用winrar自动备份重要资料
    HDU 2795 Billboard
    HDU 1140 War on Weather
  • 原文地址:https://www.cnblogs.com/hsapphire/p/11161009.html
Copyright © 2011-2022 走看看