Update demo
This commit is contained in:
parent
36b1d2364d
commit
f4dde9685a
@ -12,21 +12,41 @@ pip install wcferry
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
import logging
|
||||
from threading import Thread
|
||||
|
||||
from wcferry import Wcf
|
||||
|
||||
logging.basicConfig(level='DEBUG', format="%(asctime)s %(message)s")
|
||||
LOG = logging.getLogger("Demo")
|
||||
|
||||
|
||||
def process_msg(wcf: Wcf):
|
||||
"""处理接收到的消息"""
|
||||
while wcf.is_receiving_msg():
|
||||
try:
|
||||
msg = wcf.get_msg()
|
||||
except Exception as e:
|
||||
continue
|
||||
|
||||
LOG.info(msg) # 简单打印
|
||||
|
||||
|
||||
def main():
|
||||
LOG = logging.getLogger("Demo")
|
||||
LOG.info("Start demo...")
|
||||
wcf = Wcf(debug=True) # 默认连接本地服务
|
||||
# wcf = Wcf("tcp://127.0.0.1:10086") # 连接远端服务
|
||||
|
||||
LOG.info(f"Is Login: {True if wcf.is_login() else False}")
|
||||
LOG.info(f"SelfWxid: {wcf.get_self_wxid()}")
|
||||
LOG.info(f"已经登录: {True if wcf.is_login() else False}")
|
||||
LOG.info(f"wxid: {wcf.get_self_wxid()}")
|
||||
|
||||
wcf.enable_recv_msg(LOG.info)
|
||||
# wcf.disable_recv_msg() # Call anytime when you don't want to receive messages
|
||||
# 允许接收消息
|
||||
# wcf.enable_recv_msg(LOG.info) # deprecated
|
||||
|
||||
# 允许接收消息
|
||||
wcf.enable_receiving_msg()
|
||||
Thread(target=process_msg, name="GetMessage", args=(wcf,), daemon=True).start()
|
||||
|
||||
# wcf.disable_recv_msg() # 当需要停止接收消息时调用
|
||||
|
||||
ret = wcf.send_text("Hello world.", "filehelper")
|
||||
LOG.info(f"send_text: {ret}")
|
||||
@ -43,12 +63,11 @@ def main():
|
||||
|
||||
# wcf.accept_new_friend("v3", "v4") # 需要真正的 V3、V4 信息
|
||||
|
||||
# Keep running to receive messages
|
||||
# 一直运行
|
||||
wcf.keep_running()
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
logging.basicConfig(level='DEBUG', format="%(asctime)s %(message)s")
|
||||
main()
|
||||
|
||||
```
|
||||
|
Loading…
Reference in New Issue
Block a user