把消息处理的一部分提到了worker的步骤，希望能快一些
merge