生产者被提前关闭了,如果是进程测试的话,在结束的时候,休眠一下,给缓存的消息一个时间发送。