问题是这样的:
<code>一个微博系统,客户端调用PHP服务对某条微博发表评论,插入数据库成功需要推送给微博主人。 但是推送用的第三方API,不能保证很快返回成功与否的信号,这样这个发表评论的服务就一直等待,也不给客户端传成功的信号。 </code>
然后:
等到超过了服务的最大限制运行时间就啥都不返回给客户端,客户端提示服务错误。
等到超过了客户端的最大限制网络连接时间就提示网络错误。
我现在想实现的是,只要插入数据库成功就返回信号,推送的工作单独来做,存在几个问题:
1.如果用cron定时任务+评论是否推送标示,这样每秒就要查一遍数据库看看是否有没有推送的数据,然后推送,这样对数据库压力太大了,浪费系统资源。
2.如果是分布式,是否有更好更正规的方法...我感觉我就是个野战军...
问题是这样的:
<code>一个微博系统,客户端调用PHP服务对某条微博发表评论,插入数据库成功需要推送给微博主人。 但是推送用的第三方API,不能保证很快返回成功与否的信号,这样这个发表评论的服务就一直等待,也不给客户端传成功的信号。 </code>
然后:
等到超过了服务的最大限制运行时间就啥都不返回给客户端,客户端提示服务错误。
等到超过了客户端的最大限制网络连接时间就提示网络错误。
我现在想实现的是,只要插入数据库成功就返回信号,推送的工作单独来做,存在几个问题:
1.如果用cron定时任务+评论是否推送标示,这样每秒就要查一遍数据库看看是否有没有推送的数据,然后推送,这样对数据库压力太大了,浪费系统资源。
2.如果是分布式,是否有更好更正规的方法...我感觉我就是个野战军...
python ssdb 做个推送队列不难
用队列的方式,当有推送的工作时,先把推送工作堆入队列,直接返回成功的信号。让队列后台完成这些耗时的操作,推荐rabbitmq
用队列就好了,直接将同步的耗时操作转成异步的操作,但是异步后就会带来前端延迟的问题。所以整个完整的解决方案应该是,用户发起评论后,将评论请求写任务队列,并返回成功给客户端,但此时由于评论请求并没有真正执行,因此用户想要读此评论消息时,应该从任务队列中读取相关消息,如果没有读到,再去DB中拉取此消息。