这家伙太懒,什么都没留下
你的代码不清楚,所以建议求你消费者程序还原官网的,什么都不要动,如果不丢消息,那你在检查自己的。
继承,不是集成,写错了
多线程?呃,在消费者代码我我倒是集成了线程,难道是这个原因?
如果消费者也是官网的例子的话,消费者不是多线程,并且有休眠,消费者组名没有被其他线程同时启动,那我实在想不出来为何会丢消息了。抱歉
问题应该出在consumer中吧,发送没问题,接收少了