程序流程是这样的:
socket客户端接收一批报文, 调用某个接口对这些消息进行处理
要求接收报文后,所有数据在异常情况下保存,例如 memory mapped file
当我服务器挂掉时,这部分已接收但是没有被处理的数据,能在重启后,接着被处理,而不是重新请求数据再次接收 ,各位大神,这个功能怎么实现
客户端接收一批报文, 调用某个接口对这些消息进行处理 服务器挂掉时,这部分已接收但是没有被处理的数据,能在重启后,接着被处理,而不是重新请求数据再次接收 此处不用数据库 数据不容易丢失的方法才行
消息中间件持久化存储,这个是比较成熟的业务方案######谢了 我自己考虑的也是使用中间件存储######是否可以做一个节点来专门保存用户发过来的报文,这个节点只是起到数据恢复作用。######是指? 类似于jms吗?######这个看自己业务,还有实现方式吧######一般都会保存原始的用户数据 ,以便用来分析######例如存放于磁盘吗? 现不考虑database 实时的话 是不是有点消耗性能了?######引入中间件吧,比如消息队列,在收到请求后,先将报文放入中间件,并持久化,后面的根据你的业务可以任意变化######谢了 我自己考虑的也是使用中间件存储###### 你说的服务器挂了是指接口的服务器吗。
其实你可以把报文的消息写文件到你的本地磁盘,在发生异常的时候。在判断接口服务是否恢复,在读取本地磁盘的未被处理的报文数据,在重新执行接口调用。执行成功后在把文件删除。
######不知道你这个错误率是多大的,写磁盘频率有多高。如果频率不是很高,写磁盘对性能并不会造成很大的影响。除非你的应用并发很高,出错率也很高,那你倒是可以考虑消息队列。要不然成本有点高。######接收消息为实时,如果实时操作文件IO的话 我个人感觉 为了这么个预防的功能,拖低了整体的运行效率了吧?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。