معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

deepfos系统使用的unix socket协议

ویژگی	مقدار
سیستم عامل	-
نام فایل	deepfos-ipc-protocol-1.2.1
نام	deepfos-ipc-protocol
نسخه کتابخانه	1.2.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	chenxingyu
ایمیل نویسنده	chenxingyu1021@mail.com
آدرس صفحه اصلی	-
آدرس اینترنتی	https://pypi.org/project/deepfos-ipc-protocol/
مجوز	-

## 介绍本项目提供Python进程间通信的基础功能，适用于多进程编程中一主多从的编程模型。项目中的Server可在主进程启动，Client在（多个）子进程中启动，客户端发送的消息能够被服务端接收，并且对于不同的消息类型，可以注册不同的回调逻辑。项目预置了一些常用通信协议，同时也提供简便的自定义通信协议的接口。进程间通信基于unix socket实现，因此不能在windows系统中运行。 ## Quick Start 1. 启动服务端 ```python from dip import Server import asyncio def cb(req, mtype, data): print(data['hello']) server = Server('/tmp/run.sock', callback=cb) asyncio.run(server.serve_forever()) ``` 2. 使用客户端发送消息 ```python from dip import Client cli = Client('/tmp/run.sock') cli.send_json({'hello': 'world'}) ``` 服务端将会输出 ```python >>> 'world' ``` ## 自定义通信协议如果需要自定义进程间通信时传输字节流的格式，可以使用自定义`Protocol` ```python import typing from dip import Protocol class NewProtocol(Protocol, mtype=b'N'): @classmethod def _decode(cls, buf: bytes) -> typing.Any: pass @classmethod def _encode(cls, data: typing.Any) -> bytes: pass ``` 自定义通信协议需要使用一个byte作为标识（mtype），并且必须实现`_decode`和`_encode`两个方法。其中: > 1. `_encode` 用于将python对象序列化为字节流 > 2. `_decode` 用于将字节流反序列化为python对象两者一般互为逆操作，即对于python对象`obj`： ```python obj == Protocol.decode(Protocol.encode(obj)) ``` *注: 这并不是硬性规定，只是一种通常做法* 下述是一个非常粗糙的固定字符串压缩协议的实现 ```python from dip import Protocol from dip import errors class StringMappingProto(Protocol, mtype=b'S'): MAP = { 'Hello World': b'h', } MAP_REV = { v: k for k, v in MAP.items() } @classmethod def _decode(cls, buf: bytes) -> str: data = cls.MAP_REV.get(buf) if data is not None: return data else: raise errors.ProtoDecodeError(f'Cannot decode byte: {buf!r}') @classmethod def _encode(cls, data: str) -> bytes: compressed = cls.MAP.get(data) if compressed is not None: return compressed else: raise errors.ProtoEncodeError(f'Cannot encode string: {data!r}') ``` 使用客户端发送消息: ```python cli.send_msg('S', 'Hello World') ``` 将会在服务端接收到消息 `Hello World`

نیازمندی

مقدار	نام
~=0.5.3	loguru

زبان مورد نیاز

مقدار	نام
>=3.8.3	Python

نحوه نصب

نصب پکیج whl deepfos-ipc-protocol-1.2.1:

pip install deepfos-ipc-protocol-1.2.1.whl

نصب پکیج tar.gz deepfos-ipc-protocol-1.2.1:

pip install deepfos-ipc-protocol-1.2.1.tar.gz