a2s/a2s/demo/server.py

from a2s.a2s_server import watch, simple_params

#方式一 使用简单方式启动   .py文件命令行参数   python server.py --h
@simple_params
@watch
def main(data: bytes, *args, **kwargs) -> bytes:
    '''

    :param data: 固定格式
    :param args: 固定格式
    :param kwargs: 固定格式
    :return:
    '''
    # 内部处理程序
    data = data.decode("utf-8")
    data += "服务端处理过了数据"
    return data.encode("utf-8")

main()
# 方式二 使用简单方式启动   .py文件命令行参数   python server.py --h

@watch
def main(data: bytes, *args, **kwargs) -> bytes:
    '''

    :param data: 固定格式
    :param args: 固定格式
    :param kwargs: 固定格式
    :return:
    '''
    # 内部处理程序
    data = data.decode("utf-8")
    data += "服务端处理过了数据"
    return data.encode("utf-8")

main(nats_host="192.168.3.240",nats_port=19090,subject="test",queue="main")