需求

实现客户端和服务端的tcp长链接通信 完成数据交换

基础功能

• 动态调整服务端设置提高性能
• 心跳检测
• 闲时检测 清除或处理长时间无响应客户端
• 自动编/解码
• 自定义数据包编码 实现 256 种操作的解析（可拓展）
• 支持任意类型数据的发送，配合操作解析
• 基于JWT 的登录认证
• 授权检查，清除未授权客户端
• 消息确认ACK
• 非主动下线的断线检测与重连
• 支持客户端查询与下线等操作
• 微服务化 支持其他服务动态调用
• 支持websocket
• 支持多种序列化方式（现暂json）
• ssl 通道加密 保证数据安全
• data数据加密 保证数据安全
• ID 规则设计 便于后期分布式拓展
• session信息持久化或缓存
• 异常监控 便于错误发现
• 日志 便于错误处理
• 线程池 提高执行效率 缓解通道压力
• 数据压缩 提高传输效率

Python 简单数据处理

互联网中常见的数据基本基于 json xml 或者 html。本文介绍几种个人常用的组件，下载方式自行搜索，文中api仅供参考

json

Python自带json库，转换后和字典的操作方式相同

常用api：

• json.loads() 字符转json
• json.dumps() json转字符

python requests

requests 是出入python时就接触的网路请求神器，在学习了这么久后总结一些经验保存、学习。
这也是第一个python博客，顺便吐槽下 python的源码 注释真少 = = 好多都必须得看doc才能了解

安装

1
2
3

pip install requests
or
conda install requests (Anaconda)

jackson

在 rabbitMq 中还有个重要的组件是 MessageConverter，用于消息格式的设置。
默认使用amqp的 SimpleMessageConverter 使用text传输，在传输量较大的数据时比较消耗性能。
另一种就是 Jackson2JsonMessageConverter，使用json传输。

消息队列

单线程中间件，主要用于异步通知、消息分发、缓存、分布式事务等场景。

RabbitMQ

主要有Exchange 交换器 和 Queue 队列功能组件。
生产者会向Exchange发送消息并且绑定一个RoutingKey，
Exchange 用来接收生产者发送的消息并通过模式和规则将这些消息路由给服务器中的队列，
Exchange通过BindingKey找到匹配的队列，Queue 用来保存消息直到发送给消费者。