java项目消息处理总结
1: 实现整体框架,采用rabbitmq消息通信,多线程处理。
2: 对消息处理器实现分发器(分发消息),另可增加消息记录监控器(记录消息,图未显示)。
3:业务线程,处理业务,抽象业务的基类,然后继承实现多功能业务。
4: 多线程管理方式,采用管理器,或者线程池(此处未采用)。
5: 消费初始源--->分离器队列--->分发到每一个线程(必须用于每一个线程,即一开始把线程注册到分离器中,分离器的注册方法)
---->消费完了之后----->返回的消息---->通过分离器返回到消费源中(每一个线程,必须拥有分离器,分离器的接受消息与发送消息的方法)