Spring云流集成流与Rabbitmq消息传递，消费者提供ASCII号码作为消息有效载荷

Question

我正在使用SpringCloudStream进行消息传递。在消费者部分，我使用IntegrationFlow来监听队列。它正在监听并打印来自制作人的信息。但格式不同，这是我现在面临的问题。生产者的内容类型是application/json，IntegrationFLow消息负载显示ASCII数字。下面给出了为消费者编写的代码

 @EnableBinding(UserOperationConsume.class)
 public class ConsumerController {

   @Bean
   IntegrationFlow consumerIntgrationFlow(UserOperationConsume u) {
     return IntegrationFlows
     .from(u.userRegistraionProduces())
     //.transform(Transformers.toJson()) // not working as expected
     //.transform(Transformers.fromJson(UserDTO.class))
     .handle(String.class, (payload, headers) -> {
     System.out.println(payload.toString()); // here the output is 123,34,105,100,34,58,49,44,34,110,97,109,101,34,58,34,86,105,115,104,110,117,34,44,34,101,109,97,105,108,34,58,34,118... 
     return null;
     }).get();
  }

 }

输入接口是，

 public interface UserOperationConsume {
  @Input
  public SubscribableChannel userRegistraionProduces();
 }

消费者的yml配置是，

 server:
   port: 8181

 spring:
   application:
   name: nets-alert-service
 ---
 spring:
   cloud:
     config:
       name: notification-service
       uri: http://localhost:8888
 ---    
 spring:
   rabbitmq:
     host: localhost
     port: 5672
     username: guest
     password: guest

   ---
   spring:
     cloud:
       stream:
         bindings:
           userRegistraionProduces:
             destination: userOperations
         input:
           content-type: application/json

我试过了。类绑定，那一次我从队列中得到了一条确切的消息。因此，如果这个IntegrationFlow配置中有任何错误，请告诉我。因为我是spring cloud stream和IntegrationFlow的新手。有没有办法将这个ascii转换成精确的字符串？提前谢谢

Answer 1

使用IntegrationFlows。from（channel）不提供任何转换提示，因此您只需获取原始的字节[]有效负载（包含JSON）。不清楚为什么要使用toJson（）转换器。

你的。句柄（String.class，（有效载荷，标题）-

在任何情况下，您都没有正确使用该框架。使用

@StreamListener("userRegistraionProduces")
public void listen(UserDTO dto) {
    System.out.println(dto);
}

...框架会为你处理转换。或者...

@StreamListener("userRegistraionProduces")
public void listen(Message<UserDTO> dtoMessage) {
    System.out.println(dtoMessage);
}

如果你的制作人在标题中传达额外信息。

编辑

如果你更喜欢自己做转换，这很好。。。

@Bean
IntegrationFlow consumerIntgrationFlow(UserOperationConsume u) {
    return IntegrationFlows.from(u.userRegistraionProduces())
            .transform(Transformers.fromJson(UserDTO.class))
            .handle((payload, headers) -> {
                System.out.println(payload.toString());
                return null;
            }).get();
}

...因为Json转换器可以读取字节[]。