无法在RabbitMQ接收器中将content\u类型从应用程序/八位字节流更改为应用程序/json

Question

我有一个简单的RabbitMQ源和接收器。我正在将消息发布到具有以下属性的源队列：

content_type -> application/json

和JSON负载：

{
  "userId": 2,
  "customerId": 1,
}

RabbitMQ接收器使用application/octet-stream而不是JSON获取消息。

我尝试使用以下属性启动应用程序：

spring.cloud.stream.default.contentType=application/json

但这于事无补。

流定义：

stream_1=rabbitSource: rabbit --queues=queue1 --password=p --host=h --username=u | sink: rabbit --exchange=ex --routing-key=rk --converter-bean-name=jsonConverter --password=p --host=h --username=u

如何将内容类型设置为应用程序/json？参考指南似乎没有答案。

发布版本：

• spring-cloud-dataflow-server：2.0.1。释放
• spring-cloud-skiper-server：2.0.0。释放

更新：

正如@SabbyAnandan在回答中所建议的，我现在正在跑步：

dataflow:>stream create --name test123 --definition "rabbitSource: rabbit --queues=queue --password=p --host=rmq --username=u --spring.cloud.stream.bindings.output.contentType='application/json' | sink: rabbit --exchange=ex --routing-key=rk --converter-bean-name=jsonConverter --password=p --host=rmq --username=p"
Created new stream 'test123123'

dataflow:>stream deploy --name test123 --properties "app.rabbit.spring.cloud.stream.bindings.output.contentType='application/json'"
Deployment request has been sent for stream 'test123'

但是content_type还是一样的。

Answer 1

Rabbit源的标题中设置的默认内容类型是：<代码>内容类型：应用程序/x-java-serialized-object。

您可以通过传递以下内容来覆盖该行为：

1） <代码>--Spring。云流动绑定。输出contentType='application/json'作为Rabbit源的内联属性。

2） 部署流时，您可以通过properties=“app.rabbit.spring.cloud.stream.bindings.output.contentType='application/json”覆盖特定于应用程序的属性。

部署后，您可以通过转到特定于应用程序的超文本传输协议来确认属性是否被覆盖：//

要解决所有这些问题，您可以独立运行应用程序（即java-jar...）以在通过SCDF运行它们之前确认行为。如果它独立工作，它也应该在SCDF中工作。

Answer 2

@Maroun，正如所讨论的，这里有一些选项。

1. Rabbit接收器始终以字节[]的形式接收数据。您可以通过提供配置（rabbit.converterBeanName=jsonConverter）来强制它使用json转换器。但这在默认情况下使用Base64编码器，生成的文本将进行Base64编码。然后，在从接收器发布到的exchange接收数据的自定义应用程序中，您需要提供一个自定义转换器，该转换器使用Base64解码器进行属性解码