RabbitMQ (RPC) 和 Apache Camel 在简单的请求回复中无法正常工作

哈喽！今天心血来潮给大家带来了《RabbitMQ (RPC) 和 Apache Camel 在简单的请求回复中无法正常工作》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！

希望你一切都好！首先，我是 eip 世界的新手。我正在尝试使用以下命令进行简单的请求回复：

• golangrabbitmq 客户端
• kotlin 中的 apache camel 路由充当 rabbitmq 服务器

我尝试阅读所有可以阅读的文档并寻找答案，但我什么也没找到。我基本上已经绝望了。主要是我看到了这个，但还没有起作用。

我的目标是像图像一样进行同步请求-回复。

我的 golang 客户端如下所示：

func (r *rabbitmqconn) getqueue(name string) *amqp.queue {
    ch := r.getchannel()
    defer ch.close()
    q, err := ch.queuedeclare(
        name,
        false,
        false,
        true,
        false,
        nil,
    )
    if err != nil {
        panic(err)
    }
    return &q
}

func (r *rabbitmqconn) publishandwait(routingkey string, correlationid string, event domain.synceventextsend) (domain.synceventextreceive, error) {
    message, err := json.marshal(event)
    if err != nil {
        return domain.synceventextreceive{}, apperrors.errinternal
    }
    ch := r.getchannel()
    defer ch.close()
    q := r.getqueue("response")
    h, err := ch.consume(
        q.name,
        "",
        true,
        false,
        false,
        false,
        nil,
    )

    if err != nil {
        return domain.synceventextreceive{}, err
    }
    ctx, cancel := context.withtimeout(context.background(), 10*time.second)
    defer cancel()
    err = ch.publishwithcontext(
        ctx,
        "",
        routingkey,
        false,
        false,
        amqp.publishing{
            contenttype:   "application/json",
            body:          message,
            correlationid: correlationid,
            replyto:       q.name,
        },
    )
    if err != nil {
        return domain.synceventextreceive{}, err
    }

    for d := range h {
        fmt.println("received a message:", string(d.body))
        if d.correlationid == correlationid {
            var event domain.synceventextreceive
            err = json.unmarshal(d.body, &event)
            return event, err
        }
    }
    return domain.synceventextreceive{}, apperrors.errinternal
}

基本上，只是从带有命名响应队列的默认交换中进行消费。另外，我将队列名称作为 replyto 参数发送，并为其提供一个相关 id。在本例中，发送的路由密钥是 daily-weather。

在服务器端，我尝试使用默认交换来执行服务器操作，但 apache camel 禁止我对该交换执行任何操作。

from("rabbitmq:?queue=daily-weather&autoack=true&autodelete=false")

因此，我为其指定了 amq.direct 交换。然而，这并没有奏效。

"rabbitmq:amq.direct?queue=daily-weather&autoack=true&autodelete=false"

然后，我添加了第二个 rabbitmq 端点以查看它是否会发送它，但什么也没发送。

from("rabbitmq:amq.direct?queue=daily-weather&autoAck=true&autoDelete=false")
        .log(LoggingLevel.INFO, "weather-daily", "Received message: \${body}")
        .to("rabbitmq:amq.direct?queue=response&autoAck=true&autoDelete=false")

我问是否有人有任何使用 apache camel 执行此操作的简单示例，因为我非常迷失。如果您联系我，可以分享任何进一步的细节。

非常感谢！！！！ :)

正确答案

已解决

嗨！一段时间后，我决定看看 spring-rabbitmq camel 组件。我意识到camel有exchange patterns，而rabbitmq默认将其设置为inout。这样，信息会自动返回到 replyto 属性。

val RABBIMQ_ROUTE =
      "spring-rabbitmq:default?queues={{rabbitmq.weather.daily.routing_key}}"

default 指的是默认交换队列。

终于介绍完啦！小伙伴们，这篇关于《RabbitMQ (RPC) 和 Apache Camel 在简单的请求回复中无法正常工作》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！