我已经使用 Netty 4 编写了一个 SMPP 3.4 消息传递系统。一旦我收到一个新的消息提交(submit_sm 数据包),我很乐意在平台上接受它,我写回一个 smpp 响应,然后将接受的消息写到一个本地持久队列(例如,可能是数据库)。
假设 JDBC 作为这个例子的消息存储;耐用性和一致性是关键,虽然我不能将 JDBC 插入和 SMPP 套接字写入都包装到一个事务中,但我至少希望在 smpp 响应 channel 写入操作失败时恢复 JDBC 插入。
我目前的方法是维护一个新的线程池,在单个线程中处理 JDBC 插入和 SMPP 响应。首先,我将消息插入数据库,然后调用 channel.writeAndFlush().awaitUninterruptibly() 以检查操作是否成功完成。如果操作失败,我可以回滚数据库事务。
这看起来是正确的方法吗?我不能在 ChannelFuture 上使用 ChannelFutureListener,因为我需要留在同一个线程中以免破坏事务边界。我假设在我的方法中,必须有一些来自所选 IO 线程和我为 IO 操作结果阻塞的线程的通信?
一切顺利
乔恩
最佳答案
将接收到的请求分派(dispatch)到另一个线程池以处理 JDBC 事务并从 JDBC 线程调用 channel.write*()
完全没问题。
要记住的一件事是,即使您的 write future 已实现,peer 也有可能收不到您的响应。一个 fulfilled write future 只告诉你 O/S 接受了你的写请求。 O/S 的 TCP/IP 堆栈将尽力向对等方发送响应,但如果连接永久断开,它最终将失败。
在这种情况下,客户端很可能会重新尝试请求,这将导致重复交易。为避免这种情况,通常每个请求都有某种标识符,服务器会保留最近的请求 ID 列表以拒绝重复请求。
https://stackoverflow.com/questions/22248608/