1: 实现整体框架,采用rabbitmq消息通信,多线程处理。

2: 对消息处理器实现分发器(分发消息),另可增加消息记录监控器(记录消息,图未显示)。

3:业务线程,处理业务,抽象业务的基类,然后继承实现多功能业务。

4: 多线程管理方式,采用管理器,或者线程池(此处未采用)。

5: 消费初始源--->分离器队列--->分发到每一个线程(必须用于每一个线程,即一开始把线程注册到分离器中,分离器的注册方法) 
---->消费完了之后----->返回的消息---->通过分离器返回到消费源中(每一个线程,必须拥有分离器,分离器的接受消息与发送消息的方法)



java项目消息处理总结



相关文章:

  • 2022-12-23
  • 2021-12-23
  • 2022-12-23
  • 2021-12-16
  • 2022-12-23
  • 2021-07-26
猜你喜欢
  • 2021-06-19
  • 2022-12-23
  • 2021-09-25
  • 2022-12-23
  • 2022-12-23
  • 2021-10-16
  • 2021-12-09
相关资源
相似解决方案