也是弹幕网站（特别是A）常见问题。
http://www.cnbeining.com/isletvcloudworking.html
自取。
P.S：开始总结写的乱七八糟的东西，集合整理一下方便查找。

不错吧。
真有人拿去玩了。。。
 
https://gist.github.com/cnbeining/6b2273d7e332f29193d0
Continue reading →

应求，就这样。
什么Queue啊都不用了，投入list的怀抱吧。
https://gist.github.com/cnbeining/6b2273d7e332f29193d0

#!/usr/bin/env python
#coding:utf-8
# Author:  Beining --<cnbeining#gmail.com>
# Purpose: A simple script to get lots of viewers of Bilibili Live
# Created: 08/11/2015
# Error report: http://www.cnbeining.com/?p=952
# https://github.com/cnbeining  somewhere within my gists
import sys
import time
import getopt
from multiprocessing import Process
from websocket import create_connection, WebSocketConnectionClosedException
#----------------------------------------------------------------------
def fake_connector(cid):
    """"""
    try:
        ws = create_connection('ws://livecmt.bilibili.com:88/{cid}'.format(cid = cid))
        while 1:
            time.sleep(5)
            a = ws.recv()
    except WebSocketConnectionClosedException:
        return -1
    except Exception as e:
        print(e)
        return 0
    finally:
        return
#----------------------------------------------------------------------
def main(cid, thread_number):
    """"""
    #Get a list of threads
    process_list = [Process(target=fake_connector, args=((cid, ))) for i in xrange(int(thread_number))]  #Queue? Your ass
    [i.start() for i in process_list]  #ignite every one
    try:
        while 1:
            alive_list = [i.is_alive() for i in process_list]
            print('Active thread: ' + str(len(alive_list)))
            death_position_list = [i for i, x in enumerate(alive_list) if x == False]
            if len(death_position_list) > 0:  #someone died
                print('Some died, adding {COUNT} new thread'.format(COUNT = len(death_position_list)))
                for i in death_position_list:
                    del process_list[i]
                    process_list.append(Process(target=fake_connector, args=((cid, ))))
                    process_list[-1].start()
            time.sleep(3)
    except Exception as e:
        print(e)
        for i in process_list:
            try:
                i.terminate()
            except:
                pass
        exit()
#----------------------------------------------------------------------
def usage():
    """"""
    print('''Use as:
    -c: cid, room number
    -t: thread number
    Press Ctrl+C to exit.
    ''')
if __name__=='__main__':
    argv_list = sys.argv[1:]
    try:
        opts, args = getopt.getopt(argv_list, "hc:t:",
                                   ['help', "cid=", 'thread_number='])
    except getopt.GetoptError:
        usage()
        exit()
    for o, a in opts:
        if o in ('-h', '--help'):
            usage()
            exit()
        if o in ('-c', '--cid'):
            cid = a
        if o in ('-t', '--thread_number'):
            thread_number = int(a)
    print('Getting room {cid} {thread_number} viewers...'.format(cid = cid, thread_number = thread_number))
    main(cid, thread_number)

其实是第一个正式的多进程东西。
把大部分要踩的坑都遇上了。
OSX不用这个：开Safari 自然是HTML5.
https://github.com/cnbeining/ABPlayerHTML5-Py
自取。

这个东西上次更新是去年8月8日。
时隔一年，一看当初的东西，真是不忍直视。
思路是对的：只不过太难看了。
 
重写，这样感觉圆满一些。
遇见了一堆当初碰见的坑：因为当时注释太少，都忘记了。补上。
如果用浏览器跑弹幕，有且只有这个方案能跑：HTML5的video必须用真正的HTTP服务器供源。file://不成的。
 
从开始写到现在，出了一堆wrapper，主要是Danmaku2ASS的，播放核心mpv。
Biligrab也加了这个功能。但是我还是想把视频下到本地慢慢看：因为连通性。
这个东西的初衷是对接Biligrab：现在看起来，做到了。
 
https://github.com/cnbeining/ABPlayerHTML5-Py
已经不能直接贴一片code了，因为出了依赖：需要自取，建议更新。