原文:https://www.jianshu.com/p/7aeadca0c9bd#python
看到了该网址有基于itchat的微信消息同步机器人,转过来继续研究。如下是转过来的:数据库
最近 全栈数据工程师养成攻略
的微信群已经将近500人,开了二群以后为了打通不一样微信群之间的消息,花了点时间作了个消息同步机器人,在任意群收到消息时同步到其余群,而且将聊天内容上传至数据库,以供进一步分析、统计和展现。安全
基本思路是,用 Python
模拟微信网页版登录,接收到群里消息后,对文本、图片、分享等各种消息类型分别处理,并转发至其余群。服务器
首先得有一个微信号,用于代码模拟登录。因为个人微信号得本身留着用,现阶段注册微信又必需要手机号,因而只好特地办了个电信号,用来申请了一个新的微信,微信号是 honlanbot
。虽然说彷佛能够用阿里小号来注册微信,不过据说存在反复回收和安全隐患问题,故不采用。微信
其次,须要用到一个Python库 itchat
,这个库已经作好了用代码调用微信的大多数功能,很是好用,官方文档在这里,安装的时候使用 pip
便可。ide
pip install itchat
个人手机支持双卡双待,因而把两张卡都装手机里,再双开微信,同时保持两个微信号手机在线,差很少就能够开始写代码了。用 itchat
调用微信主要是模拟微信网页版登录,因此必须保持微信号手机在线,由于手机端微信一旦退出,其在网页、PC、MAC、IPAD等相应终端认证的帐号也会随之退出。函数
itchat
提供了一些官方代码,让咱们在本身的本本或电脑上新建一个 py
文件,初步尝试一下。spa
运行如下代码,会出现出现一张二维码,扫码登录以后将会给“文件传输助手”发送一条消息。code
# 加载包 import itchat # 登录 itchat.auto_login() # 发送文本消息,发送目标是“文件传输助手” itchat.send('Hello, filehelper', toUserName='filehelper')
如下代码则注册了一个消息响应事件,用来定义接收到文本消息后如何处理。在 itchat
里能够定义文本、图片、名片、位置、通知、分享、文件等多种消息类型,从而分别执行不一样的处理。orm
import itchat # 注册消息响应事件,消息类型为itchat.content.TEXT,即文本消息 @itchat.msg_register(itchat.content.TEXT) def text_reply(msg): # 返回一样的文本消息 return msg['Text'] itchat.auto_login() # 绑定消息响应事件后,让itchat运行起来,监听消息 itchat.run()
再来看看如何处理其余类型消息,能够把在消息响应事件里把 msg
打印出来,是一个字典,看看有哪些感兴趣的字段。
import itchat # import所有消息类型 from itchat.content import * # 处理文本类消息 # 包括文本、位置、名片、通知、分享 @itchat.msg_register([TEXT, MAP, CARD, NOTE, SHARING]) def text_reply(msg): # 微信里,每一个用户和群聊,都使用很长的ID来区分 # msg['FromUserName']就是发送者的ID # 将消息的类型和文本内容返回给发送者 itchat.send('%s: %s' % (msg['Type'], msg['Text']), msg['FromUserName']) # 处理多媒体类消息 # 包括图片、录音、文件、视频 @itchat.msg_register([PICTURE, RECORDING, ATTACHMENT, VIDEO]) def download_files(msg): # msg['Text']是一个文件下载函数 # 传入文件名,将文件下载下来 msg['Text'](msg['FileName']) # 把下载好的文件再发回给发送者 return '@%s@%s' % ({'Picture': 'img', 'Video': 'vid'}.get(msg['Type'], 'fil'), msg['FileName']) # 处理好友添加请求 @itchat.msg_register(FRIENDS) def add_friend(msg): # 该操做会自动将新好友的消息录入,不须要重载通信录 itchat.add_friend(**msg['Text']) # 加无缺友后,给好友打个招呼 itchat.send_msg('Nice to meet you!', msg['RecommendInfo']['UserName']) # 处理群聊消息 @itchat.msg_register(TEXT, isGroupChat=True) def text_reply(msg): if msg['isAt']: itchat.send(u'@%s\u2005I received: %s' % (msg['ActualNickName'], msg['Content']), msg['FromUserName']) # 在auto_login()里面提供一个True,即hotReload=True # 便可保留登录状态 # 即便程序关闭,必定时间内从新开启也能够不用从新扫码 itchat.auto_login(True) itchat.run()
通过以上示例代码,能够总结出消息同步机器人的开发思路:
get_chatrooms()
获取所有群聊的数据,包括每一个群聊的ID和昵称,能够将须要同步消息的群聊保存至通信录;直接上代码好了,首先定义一个消息响应函数,文本类消息我感兴趣的是 TEXT
和 SHARING
两类,使用 isGroupChat=True
指定消息来自于群聊,这个参数默认为 False
。
# 自动回复文本等类别的群聊消息 # isGroupChat=True表示为群聊消息 @itchat.msg_register([TEXT, SHARING], isGroupChat=True) def group_reply_text(msg): # 消息来自于哪一个群聊 chatroom_id = msg['FromUserName'] # 发送者的昵称 username = msg['ActualNickName'] # 消息并非来自于须要同步的群 if not chatroom_id in chatroom_ids: return if msg['Type'] == TEXT: content = msg['Content'] elif msg['Type'] == SHARING: content = msg['Text'] # 根据消息类型转发至其余群 if msg['Type'] == TEXT: for item in chatrooms: if not item['UserName'] == chatroom_id: itchat.send('%s\n%s' % (username, msg['Content']), item['UserName']) elif msg['Type'] == SHARING: for item in chatrooms: if not item['UserName'] == chatroom_id: itchat.send('%s\n%s\n%s' % (username, msg['Text'], msg['Url']), item['UserName'])
再来处理下图片等多媒体类消息。
# 自动回复图片等类别的群聊消息 # isGroupChat=True表示为群聊消息 @itchat.msg_register([PICTURE, ATTACHMENT, VIDEO], isGroupChat=True) def group_reply_media(msg): # 消息来自于哪一个群聊 chatroom_id = msg['FromUserName'] # 发送者的昵称 username = msg['ActualNickName'] # 消息并非来自于须要同步的群 if not chatroom_id in chatroom_ids: return # 若是为gif图片则不转发 if msg['FileName'][-4:] == '.gif': return # 下载图片等文件 msg['Text'](msg['FileName']) # 转发至其余须要同步消息的群聊 for item in chatrooms: if not item['UserName'] == chatroom_id: itchat.send('@%s@%s' % ({'Picture': 'img', 'Video': 'vid'}.get(msg['Type'], 'fil'), msg['FileName']), item['UserName'])
以上代码实现了对文本、分享、图片、视频四类消息的处理,若是对其余类型的消息也感兴趣,进行相应的处理便可。在前面补上 import
的代码,在后面补上登录、获取群聊数据和开始监测的代码,就大功告成了。
完整代码在这里:https://pan.baidu.com/s/1bpAJk0B
目前两个群之间能够进行消息同步了,一群和二群的小伙伴终于能够畅快地聊了起来(当群主不容易,常常要发不少红包 = =)。
固然,我不可能一直在笔记本上运行这么个 py
代码,因此把它部署到服务器上运行就行了,开个 screen
或者用 IPython
均可以。若是帐号偶尔下线了,再运行一下就好。
另外,我还写了个 API
,响应消息的时候会把相应的数据 POST
到个人服务器并存到数据库,以供进一步的分析、统计和展现,这也是我身为一个群主应尽的职责~