Python版本Zinx——(4)全局配置

2023-08-26  本文已影响0人  爱折腾的胖子

  最近想研究一下关于长链接的相关内容,在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文件已经覆盖临时的配置。

上一篇 下一篇

猜你喜欢

热点阅读