编码导入redis类liveroom课程文字性java project.pdfVIP

#encoding:utf-8

importredis

classLiveRoom:

def__init__(self,client,live_room_name):

设置间使用的客户端，以及间的名字。

self.client=client

self.live_room_name=live_room_name

defplay(self,song_id):

播主功能，ID为song_id的歌曲。

instruct=play_song+str(song_id)

self.client.publish(self.live_room_name,instruct)

play_song(instruct)

deflisten(self):

听众功能，收听间。

#创建pubsub对象，并设置要订阅的频道

pubsub=self.client.pubsub()

pubsub.subscribe(self.live_room_name)

#接收消息

formessageinpubsub.listen():

ifmessage[type]==message:

play_song(message[data])

defcount_listener(self):

这个功能需要用到PUBSUBNUMSUB命令，

但Python的客户端似乎还未支持PUBSUB命令，

无法实现。

raise

defplay_song(instruct):

#从play_songsong_id指令中提取出song_id

song_id=int(instruct.lstrip(play_song))

print(playingsong,id={0}.format(song_id))

编码：utf-8导入redis类LiveRoom：

def__init__(self,client,live_room_name):

self.client=client

self.live_room_name=live_room_name

defplay(self,song_id):IDsong_id

instruct=play_song:+str(song_id)

self.client.publish(self.live_room_name,instruct)

play_song(instruct)deflisten(self):#pubsubpubsub=self.client.pubsub()

pubsub.subscribe(self.live_room_name)

fo