pyzmq简单的在线聊天室

#encoding=utf-8

#客户端

importzmq

c=zmq.Context()

s=c.socket(zmq.REQ)

s.connect('tcp://127.0.0.1:10001')whileTrue:

s.send(raw_input('客户端输入:'), copy=False)

msg2= s.recv(copy=False)PRint"服务器的数据:",msg2

#encoding=utf-8

#服务器

importzmq

c=zmq.Context()

s=c.socket(zmq.REP)

s.bind('tcp://127.0.0.1:10001')whileTrue:

msg= s.recv(copy=False)print"客户端的数据:",msg

s.send(raw_input("服务器输入:"))