spring-webflux - 如何将 bodyToFlux 用于从服务器发出的不同类型的子类以匹配适当的对象类型

Question

我在 http 上有发射器，它发射不同对象类型（不同子类）的事件。订阅此流的 web 客户端需要检查传输的事件类型（映射到对象类型）。在这种情况下，如何实现它作为运算符的实例不起作用

Answer 1

我在 http 上有发射器，它发射不同对象类型（不同子类）的事件

如果发射器通过 HTTP，则没有类型的概念 - 事件将是数据字符串（当然以某种方式序列化，可能使用 JSON。）您需要告诉代码它需要使用什么类型来反序列化- 因此上的类参数的存在bodyToFlux()。

如果您不确定类型，那么您可以使用bodyToFlux(Map.class)将 JSON 转换为地图 - 然后您可以检查地图以找出您想要转换的 POJO，然后从那里开始。