1. 整体的设计图如下，用的生产消费的模型

2. sever端代码设计

思路：监听端口-->初始化消费类型类似kafka的topic-->product client生产数据-->生产的数据存到数组中-->consumer client-->从数组中消费数据

3. 整代码

4. 服务端代码

5. 生产者客户端代码

6. 消费者客户端代码

7. lib包代码

8. 仅供参考学习，如有疑问欢迎留言交流。