Python如何實現(xiàn)微信群萬人同步直播？

作者：豬哥66 2019-12-16 17:25:04

開發(fā) 后端

今天我們來學習微信機器人系列的第五篇：多群轉發(fā)做同步圖文直播！

[[285721]]

很多人傳言微信網(wǎng)頁版（https://wx.qq.com/）接口已經(jīng)被封了，所以所有的微信都不能登錄網(wǎng)頁版，這是錯誤的。

2019年7月微信對網(wǎng)頁版微信進行了動態(tài)安全策略調(diào)整，導致一大批微信號不能登錄網(wǎng)頁版，但有些微信老號還是可以登錄網(wǎng)頁版的，具體哪些微信號可以登錄哪些又不能登錄，這個目前暫不了解！

今天我們來學習微信機器人系列的第五篇：多群轉發(fā)做同步圖文直播！

一、背景介紹

豬哥一年前在建Python學習群的時候就說過，要邀請企業(yè)大佬來學習群做直播。

其實文章早就寫好了，但是一直沒有找到好的轉發(fā)軟件，所以耽擱了幾個月。

最近豬哥感覺不能再拖了，所以就考慮自己開發(fā)一個多群直播項目，使用原來我們做的微信機器人項目。

需求很簡單：能做到24個微信大群（共萬人）同步轉發(fā)就可以！

相信很多公司企業(yè)也會有同樣的需求吧！

二、功能設計

如何做多群直播呢？簡單的就是用機器人做二級轉發(fā)：

新建一個直播主講群
將三個機器人和主講人拉進群里
主講人發(fā)到群里的消息機器人都自動轉發(fā)到群里
機器人轉發(fā)完畢后在主講群回復
繼續(xù)發(fā)消息

為了大家便于理解，豬哥畫了一個簡單的設計圖：

根據(jù)上圖設計，我們這次功能設計有4個主要元素：主講群、主講人、轉發(fā)群、機器人管理員。

三、功能實現(xiàn)

1.加載直播4個元素

根據(jù)上面的設計圖，我們得知首先需要一個直播主講群，然后直播群里個主講人，然后還需要加載需要轉發(fā)的轉發(fā)群。

這些信息我們都可以在寫在一個配置文件里面。

然后我們在機器人啟動的時候，調(diào)用加載配置文件的方法，而加載配置文件的方法又去調(diào)用加載直播信息的方法！

首先是加載機器人管理員，然后在方法中間去調(diào)用加載群信息的方法！

下面是load_live方法的詳細代碼，主要做三件事：加載主講群、檢查主講群里是否有主講人、加載直播群。

def load_live(bot):  
    """加載直播需要的群"""  
    # 設置開關  
    bot.is_live_mode = config.is_live_mode  
    if not bot.is_live_mode:  
        return '\n未開啟直播模式，可在 config.py 文件中將 is_live_mode 設置為True開啟！'  
    live_status_detail = ''  
    # 1、加載主講群  
    live_group = bot.groups().search(config.live_group)  
    if len(live_group) < 1:  
        bot.live_group = None  
        bot.is_live_mode = False  
        return f'\n主講群：未找到群名包含「{config.live_group}」的主講群！\n開啟群直播失敗！\n\n可在主講群中發(fā)任意消息，然后管理員使用命令：開啟群直播模式，從新加載直播信息！'  
    elif len(live_group) > 1:  
        bot.live_group = live_group[0]  
        live_status_detail += f'\n主講群：找到多個群名包含「{config.live_group}」的主講群，默認選取第一個群（{live_group[0]}）作為主講群!'  
    else:  
        bot.live_group = live_group[0]  
    # 2、加載主講人  
    live_group_members = bot.live_group.members  
    for member in live_group_members:  
        if member.name == config.live_speaker:  
            live_status_detail += f'\n主講人：「{config.live_speaker}」'  
            bot.live_speaker = config.live_speaker  
            break  
    else:  
        live_status_detail += f'\n主講人：主講群內(nèi)未找到主講人「{config.live_speaker}」。\n開啟群直播失敗！'  
        bot.is_live_mode = False  
        return live_status_detail  
    # 3、加載轉發(fā)群  
    forward_groups = search_groups(bot, config.forward_groups)  
    bot.forward_groups = forward_groups  
    live_status_detail += f'\n轉發(fā)群：消息將會轉發(fā)至這些群：{str(forward_groups)}，共{len(forward_groups)}個。\n\n如有遺漏可在這些群中發(fā)任意消息，然后管理員使用命令：開啟群直播模式，從新加載直播信息！' 
     return live_status_detail

這里我們就加載完了直播需要的4個要素：機器人管理員、主講群、主講人、轉發(fā)群。

2.實現(xiàn)轉發(fā)消息

所需要的信息都加載完畢之后，我們就可以來開始做轉發(fā)了。

大概的思路是：

定義一個接收群消息的方法
接收到群消息就判斷這條消息需不需要轉發(fā)，判斷條件是：開啟直播模式+當前消息是主講群內(nèi)的+發(fā)消息的人是主講人
如果滿足上訴三個條件，則將消息轉發(fā)到群里
轉發(fā)完畢在主講群內(nèi)回復：一轉發(fā)完畢，這時主講人就可以講下一句話

我們來看看代碼吧！

我們再來看看wx_command.remote_forward(msg)的具體代碼吧！

def remote_forward(msg):  
    """轉發(fā)消息"""  
    forward_groups = []  
    for group in msg.bot.forward_groups:  
        msg.forward(group, suffix='')  
        forward_groups.append(group.name)  
        time.sleep(random.random())  
    return forward_groups