最近想研究一下关于长链接的相关内容,在B站上看到了Zinx框架的视频,是Golang语言的框架,本着更好的理解框架的内容,按照整个Zinx课程的进度,制作一个Python版本的Zinx框架。有关于Zinx框架的具体内容,可以看框架作者的介绍。
python版本的Zinx,基于Gevent 22.10.2,使用协程功能。
golang版本的Zinx项目,项目中两个文件夹,ziface和znet。
- ziface主要是存放一些Zinx框架的全部模块的抽象层接口类。
- znet模块是zinx框架中网络相关功能的实现,所有网络相关模块都会定义在znet模块中。
└── zinx
├── ziface
│ └──
└── znet
├──
python中的关键字没有interface,但是可以使用抽象基类(abstract base class)和第三方库来实现类似于接口的功能。在实际开发中,我们可以根据具体需求选择合适的实现方式。
暂时使用抽象基类的形式模拟接口的实现。
上一节封装了基础的路由模块,本节封装一下服务器所需的配置,比如主机、端口等基础参数。
新建一个utils文件夹,创建globalobj.py文件。
# -*- coding: utf-8 -*-
from typing import Optional
from ziface.iserver import IServer
import json
import os
class GlobalObj:
def __init__(self, host: str, tcp_port: int, name: str, version: str, max_packet_size: int, max_conn: int):
self.TcpServer: Optional[IServer] = None # 当前zinx的全局Server对象
self.Host: str = host # 当前服务器主机IP
self.TcpPort: int = tcp_port # 当前服务器主机监听端口号
self.Name: str = name # 当前服务器名称
self.Version: str = version # 当前Zinx版本号
self.MaxPacketSize: int = max_packet_size # 都需数据包的最大值
self.MaxConn: int = max_conn # 当前服务器主机允许的最大链接个数
self.Reload()
def Reload(self):
"""
读取用户的配置文件,覆盖默认配置
:return:
"""
root_path = os.getcwd()
conf_path = "/conf/"
conf_name = "zinx.json"
real_path = root_path + conf_path + conf_name
if not os.path.exists(real_path):
return
with open(real_path, 'r', encoding='utf-8') as jsonfile:
data = json.load(jsonfile)
for key in data.keys():
if key in self.__dict__.keys():
self.__dict__[key] = data[key]
def SetTcpServer(self, tcp):
"""
记录一下TCPServer
:param tcp:
:return:
"""
self.TcpServer = tcp
# 全局对象
GlobalObject = GlobalObj("0.0.0.0", 8986, "ZinxServerApp", "测试版本", 4096, 12000)
# 顺便做一个全局Events
GlobalGevents: list = []
将全局参数集成到服务端中。Server文件修改一下。
# 获取server
def NewServer() -> IServer:
global m_server
if m_server:
return m_server
m_server = Server(GlobalObject.Name, GlobalObject.Host, GlobalObject.TcpPort)
GlobalObject.SetTcpServer(m_server)
return m_server
Connection文件中的GlobalEvents替换为全局GlobalEvents。
接下来再root.py文件的同级目录下,创建conf文件夹以及zinx.json文件。临时端口设置为8986,Json文件端口设置为8987。
Json文件如下:
{
"Name": "PingServer",
"Host": "0.0.0.0",
"TcpPort": 8987,
"Version": "测试版本",
"MaxPacketSize": 4096,
"MaxConn": 12000
}
服务接口做完了。在cmd中输入命令,回车
nc 127.0.0.1 8987
此时全局封装的Json文件已经覆盖临时的配置。