发明授权
摘要:
本发明提供了一种消息传输方法及装置,该方法包括:通过接收线程接收客户端发送的初始消息元组,并获取初始消息元组的任务号,基于该任务号确定目标执行器组,通过接收线程将初始消息元组传输至目标执行器组中,经过目标执行器组中包含的N个执行器依次对初始消息元组进行处理,由目标执行器组中的第N个执行器输出初始消息元组对应的目标消息元组,并将目标消息元组发送至发送线程的传输队列;通过发送线程将传输队列接收到的目标消息元组确定为待传输消息元组,并判断传输队列中存储的待传输消息元组是否满足预先设置的传输条件,若满足,则将传输队列中的待传输消息元组传输至服务端。能够节约处理器的资源,从而提升处理器的工作效率。
公开/授权文献
- CN111752728A 消息传输方法及装置 公开/授权日:2020-10-09