java - 推荐的支持消息存储的表的数据库模式是什么？

Question

我希望利用 Spring Integration 的 Resequencer，并尝试创建一个消息存储来支持它。我们使用 SQL Server 作为我们的数据库解决方案。

在查看文档时，我对我的消息存储表应该(或可能)是什么样子没有很好的理解:

17.4 JDBC Message Store

在下面文档的片段中，似乎有带有“:”语法的选项可以插入和/或查询消息属性。

<int-jdbc:outbound-gateway
update="insert into foos (id, status, name) values (:headers[id], 0, :payload[foo])"
request-channel="input" reply-channel="output" data-source="dataSource" />

<int-jdbc:outbound-gateway
update="insert into foos (status, name) values (0, :payload[foo])"
request-channel="input" reply-channel="output" data-source="dataSource"
keys-generated="true"/>

那么有完整的代币名称列表吗？ “id”是否充当 header 映射中的散列？它是否对应于一个名为“id”的消息头？对于“:payload[foo]”，“foo”代表什么？是否有适合不同消息属性的推荐列类型？

我真的在寻找指导:

1. 我的数据库模式应该是什么？ (我有什么选择)
2. 如何在我的 SI 配置中映射进和映射出该架构？ (即，如何告诉 SI 消息的哪些部分转到哪些列)

Answer 1

模式在 jar 里，可以找到in the github repo .

您需要使用与您正在使用的 Spring Integration 版本相对应的架构。

是的，headers[id] 表示 id header 。

payload[foo] 假设负载是一个 Map 并且有一个键 foo。

您可以使用任何 SpEL 表达式，例如，具有 getFoo() 的对象可以使用 payload.foo。

网关不作用于消息存储 - 它们作用于您的业务表。