1

我实现了 Message 接口以包含一些与服务器端的 HeaderValueRouter 一起使用的标头。

在一个虚拟机中，这可以工作（使用两个端点之间的过滤器进行测试）。

但是，如果我通过 HttpOutboundGatway 发送消息，我的字段将被剥离（不包含在 HttpRequest 中）。因此，路由信息在服务器端丢失。

我不应该操纵标题吗？

public class TaskMessage implements Message<String> {

    private MessageHeaders headers;
    private String payload;

    public TaskMessage(String taskId, String boxId, String payload) {
        super();
        this.taskId = taskId;
        this.boxId = boxId;
        this.payload = payload;
        StringMessage sm = new StringMessage(payload);
        Set<String> keySet = sm.getHeaders().keySet();

        HashMap<String, Object> map = new HashMap<String, Object>();
        for (String key : keySet) {
            map.put(key, sm.getHeaders().get(key));
        }
        map.put("taskId", taskId);
        map.put("boxId", boxId);
        headers = new MessageHeaders(map);
    }
    @Override
    public MessageHeaders getHeaders() {
        return headers;
    }

    @Override
    public String getPayload() {
        return payload;
    }
}

编辑：

版本是 1.0.3

我的配置部分是：

<si:inbound-channel-adapter ref="jdbcInputAdapter" method="fetchData" channel="msgChannel">
    <si:poller max-messages-per-poll="1"> 
        <si:interval-trigger interval="5000" />
    </si:poller>
</si:inbound-channel-adapter>

<http:outbound-gateway id="httpChannelAdapter" auto-startup="true" request-timeout="1000" request-channel="msgChannel" reply-channel="replyChannel" default-url="http://localhost:8080/taskserver/gateway"/>
4

1 回答 1

1

您使用的版本不支持（自定义）标头序列化。解决方案是制作一个包含所有所需信息的请求，并将其作为有效负载传递。2.0.x 版本中新的基于 REST 的 http 支持确实支持标头映射，并且还公开了用于转换消息（包括标头）的扩展点。

作为旁注，必须实现自定义消息是非常罕见的，因此我不会这样做，而是使用 MessageBuilder 创建一条消息

MessageBuilder.withPayload("foo").setHeader("taskId", "someTaskId").build();

一般而言，并非所有标头都可以通过所有协议传输，因此如果您想使用分布式系统，将需要发送的所有信息打包到有效负载中通常会更灵活。

于 2010-07-16T19:51:11.787 回答