Asyncio库上的离心机WebSocket客户端
centrifuge-python的Python项目详细描述
#离心机python（正在工作）
这是位于python异步库之上的[离心机]（https://github.com/离心机/离心机）服务器的websocket客户机。
>用法示例：
``` python
导入时间
导入json
从cent导入异步
从离心机导入客户机生成令牌
，凭据
def run（loop）：
\
user=“3000”
timestamp=str（int（time.time（））
info=json.dumps（{“名字”：“python”，“姓氏”：“client”}）
token=generate_token（“secret”，user，timestamp，info=info）
address=“ws://localhost:8000/connection/websocket”
credentials=credentials（user，timestamp，info，令牌）
client=client（地址、凭据）
离开处理程序（**Kwargs）：
打印（“离开：”，Kwargs）
从客户端获得收益。订阅（
“public:chat”，
在“消息”处理程序上，
在“连接”处理程序上，
>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\>或与python 3.5异步/等待语法：
`` python
导入时间
从离心机导入客户端导入json
import asyncio
，凭证
来自cent import generate廑token
async def run（）：
user=“3000”
timestamp=str（int（time.time（））
info=json.dumps（{“first_name”：“python”，“last_name”：“client”}）
token=generate_token（“secret”，user，timestamp，info=info）
credentials=credentials（user，timestamp，info，token）
address=“ws://localhost:8000/connection/websocket”
异步定义连接处理程序（**Kwargs）：
打印（“已连接”，Kwargs）
异步定义断开连接处理程序（**Kwargs）：
打印（“已断开：”，Kwargs）
异步定义连接错误处理程序（**Kwargs）：
打印（“错误：”，Kwargs）
client=client（
地址、凭据，
on_connect=connect_handler，
on_disconnect=disconnect_handler，
on_error=connect_error_handler
）
等待客户端。connect（）
异步定义消息处理程序（**kwargs）：
打印（“消息：”，kwargs）
异步定义连接处理程序（**kwargs）：
打印（“连接：”，kwargs）
async def leave\u handler（**kwargs）：
print（“leave:”，kwargs）
async def error\u handler（**kwargs）：
print（“sub error:”，kwargs）
wait client.subscribe（
“public:chat”，
on_message=message\u handler，
on_join=join\u handler，
on_leave=离开处理程序，
>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\是的###TOdo
*[连接刷新]（https://fzambia.gitbooks.io/centrical/content/server/connection_check.html）支持
*功能测试
*更详细的API描述
这是位于python异步库之上的[离心机]（https://github.com/离心机/离心机）服务器的websocket客户机。
>用法示例：
``` python
导入时间
导入json
从cent导入异步
从离心机导入客户机生成令牌
，凭据
def run（loop）：
\
user=“3000”
timestamp=str（int（time.time（））
info=json.dumps（{“名字”：“python”，“姓氏”：“client”}）
token=generate_token（“secret”，user，timestamp，info=info）
address=“ws://localhost:8000/connection/websocket”
credentials=credentials（user，timestamp，info，令牌）
client=client（地址、凭据）
离开处理程序（**Kwargs）：
打印（“离开：”，Kwargs）
从客户端获得收益。订阅（
“public:chat”，
在“消息”处理程序上，
在“连接”处理程序上，
>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\>或与python 3.5异步/等待语法：
`` python
导入时间
从离心机导入客户端导入json
import asyncio
，凭证
来自cent import generate廑token
async def run（）：
user=“3000”
timestamp=str（int（time.time（））
info=json.dumps（{“first_name”：“python”，“last_name”：“client”}）
token=generate_token（“secret”，user，timestamp，info=info）
credentials=credentials（user，timestamp，info，token）
address=“ws://localhost:8000/connection/websocket”
异步定义连接处理程序（**Kwargs）：
打印（“已连接”，Kwargs）
异步定义断开连接处理程序（**Kwargs）：
打印（“已断开：”，Kwargs）
异步定义连接错误处理程序（**Kwargs）：
打印（“错误：”，Kwargs）
client=client（
地址、凭据，
on_connect=connect_handler，
on_disconnect=disconnect_handler，
on_error=connect_error_handler
）
等待客户端。connect（）
异步定义消息处理程序（**kwargs）：
打印（“消息：”，kwargs）
异步定义连接处理程序（**kwargs）：
打印（“连接：”，kwargs）
async def leave\u handler（**kwargs）：
print（“leave:”，kwargs）
async def error\u handler（**kwargs）：
print（“sub error:”，kwargs）
wait client.subscribe（
“public:chat”，
on_message=message\u handler，
on_join=join\u handler，
on_leave=离开处理程序，
>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\是的###TOdo
*[连接刷新]（https://fzambia.gitbooks.io/centrical/content/server/connection_check.html）支持
*功能测试
*更详细的API描述
欢迎加入QQ群-->： 979659372
