jdbc - 在 Netty 消息处理中使用 JDBC 事务

Question

我已经使用 Netty 4 编写了一个 SMPP 3.4 消息传递系统。一旦我收到一个新的消息提交(submit_sm 数据包)，我很乐意在平台上接受它，我写回一个 smpp 响应，然后将接受的消息写到一个本地持久队列(例如，可能是数据库)。

假设 JDBC 作为这个例子的消息存储；耐用性和一致性是关键，虽然我不能将 JDBC 插入和 SMPP 套接字写入都包装到一个事务中，但我至少希望在 smpp 响应 channel 写入操作失败时恢复 JDBC 插入。

我目前的方法是维护一个新的线程池，在单个线程中处理 JDBC 插入和 SMPP 响应。首先，我将消息插入数据库，然后调用 channel.writeAndFlush().awaitUninterruptibly() 以检查操作是否成功完成。如果操作失败，我可以回滚数据库事务。

这看起来是正确的方法吗？我不能在 ChannelFuture 上使用 ChannelFutureListener，因为我需要留在同一个线程中以免破坏事务边界。我假设在我的方法中，必须有一些来自所选 IO 线程和我为 IO 操作结果阻塞的线程的通信？

一切顺利

乔恩

Answer 1

将接收到的请求分派(dispatch)到另一个线程池以处理 JDBC 事务并从 JDBC 线程调用 channel.write*() 完全没问题。

要记住的一件事是，即使您的 write future 已实现，peer 也有可能收不到您的响应。一个 fulfilled write future 只告诉你 O/S 接受了你的写请求。 O/S 的 TCP/IP 堆栈将尽力向对等方发送响应，但如果连接永久断开，它最终将失败。

在这种情况下，客户端很可能会重新尝试请求，这将导致重复交易。为避免这种情况，通常每个请求都有某种标识符，服务器会保留最近的请求 ID 列表以拒绝重复请求。