zoukankan      html  css  js  c++  java
  • krakend 消费amqp mq 消息

    krakend 支持amqp mq 的消息消费以及发送,可以实现(http2xxx)
    具体的参数配置可以参考官方文档

    消费消息参考配置

     
        "backend": [
            {
                "host": [
                    "amqp://guest:guest@myqueue.host.com:5672"
                ],
                "disable_host_sanitize": true,
                "extra_config": {
                    "github.com/devopsfaith/krakend-amqp/consume": {
                        "name":           "queue-1",
                        "exchange":       "some-exchange",
                        "durable":        true,
                        "delete":         false,
                        "exclusive":      false,
                        "no_wait":        true,
                        "no_local":       false,
                        "routing_key":    ["#"],
                        "prefetch_count": 10
                    }
                }
            }

    发布消息

        "endpoint": "/producer",
        "headers_to_pass": [ "...", "..." ],
        "backend": [
            {
                "host": [
                    "amqp://guest:guest@myqueue.host.com:5672"
                ],
                "disable_host_sanitize": true,
                "extra_config": {
                    "github.com/devopsfaith/krakend-amqp/produce": {
                        "name": "queue-1",
                        "exchange":       "some-exchange",
                        "durable":        true,
                        "delete":         false,
                        "exclusive":      false,
                        "no_wait":        true,
                        "mandatory": true,
                        "immediate": false
                    }
                }
            }

    参考资料

    https://www.krakend.io/docs/backends/amqp/

  • 相关阅读:
    【Ansible】 各种模块
    【Python】 linecache模块读取文件
    【Ansible】 基于SSH的远程管理工具
    【Python】 更棒的Excel操作模块xlwings
    【Python】 docker-py 用Python调用Docker接口
    【Docker】 Swarm简单介绍
    【Docker】 积累
    【Bootstrap】 一些提示信息插件
    配置 -- php运行报Call to undefined function curl_init()的解决办法
    windows下svn钩子实现每次提交更新至web目录
  • 原文地址:https://www.cnblogs.com/rongfengliang/p/14192067.html
Copyright © 2011-2022 走看看