pyzmq简单的在线聊天室

#encoding=utf-8
#客户端

import zmq

c = zmq.Context()

s = c.socket(zmq.REQ)

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

while True:

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

    msg2 = s.recv(copy=False)

    print "服务器的数据:",msg2

#encoding=utf-8
#服务器

import zmq

c = zmq.Context()

s = c.socket(zmq.REP)

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

while True:

    msg = s.recv(copy=False)

    print "客户端的数据:",msg

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