#!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 import select

 sk = socket.socket()

 sk.bind(('127.0.0.2', 9001))

 sk.listen()

 sk1 = socket.socket()

 sk1.bind(('127.0.0.2', 9002))

 sk1.listen()

 sk2 = socket.socket()

 sk2.bind(('127.0.0.2', 9003))

 sk2.listen()

 inputs = [sk, sk1, sk2]

 while True:

     # [sk, sk1, sk2]select 内部自动监听sk1，sk，sk2三个对象，一旦某个句柄

     # 如果有人连接sk1，sk2

     # r_list = [sk1，sk2]

     r_list, w_list, e_list = select.select(inputs, [], [], 1)

     # 1,是等待1秒的意思

     for sk in r_list:

         conn, address = sk.accept()

         conn.sendall(bytes('hello', encoding='utf-8'))

         conn.close()

     for sk in e_list:

         inputs.remove(sk

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 9001))

 content = str(obj.recv(1024), encoding='utf-8')

 print(content)

 obj.close()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 9002))

 content = str(obj.recv(1024), encoding='utf-8')

 print(content)

 obj.close()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 9003))

 content = str(obj.recv(1024), encoding='utf-8')

 print(content)

 obj.close()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 import select

 sk1 = socket.socket()

 sk1.bind(('127.0.0.2', 9000))

 sk1.listen()

 inputs = [sk1]

 while True:

     # r_list 中一开始只有服务器sk1，小军连接时，会把小军加入到inputs

     r_list, w_list, e_list = select.select(inputs, [], inputs, 1)

     # 1,是等待1秒的意思

     print('正在监听的socket对象%d' % len(inputs))

     print(r_list)

     for sk1_or_conn in r_list:

         # 每一个连接对象

         if sk1_or_conn == sk1:

             conn, address = sk1_or_conn.accept()

             inputs.append(conn)

         else:

             try:   # 有老用户发消息了

                 data_bytes = sk1_or_conn.recv(1024)

                 data_str = str(data_bytes,encoding='utf-8')

                 sk1_or_conn.sendall(bytes(data_str+'好', encoding='utf-8'))

             except Exception as ex:

                 inputs.remove(sk1_or_conn)

 # 只需重复运行三次即可

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 9000))

 while True:

     inp = input('>>>>')

     obj.sendall(bytes(inp, encoding='utf-8'))

     ret = str(obj.recv(1024), encoding='utf-8')

     print(ret)

 obj.close()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socketserver

 class MyServer(socketserver.BaseRequestHandler):

     def handle(self):

         conn = self.request  # request 不要加括号，加括号显示不出来东西，

         conn.sendall(bytes('欢迎来到梦幻西游', encoding='utf-8'))

         while True:

             ret_bytes = conn.recv(1024)

             ret_str = str(ret_bytes, encoding='utf-8')

             if ret_str == 'q':

                 break

             conn.sendall(bytes(ret_str + "好", encoding='utf-8'))

 if __name__ == '__main__':

     server = socketserver.ThreadingTCPServer(('127.0.0.2', 1324), MyServer)

     server.serve_forever()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 1324))

 # 阻塞

 re_bytes = obj.recv(1024)

 ret_str = str(re_bytes, encoding='utf-8')

 print(ret_str)

 while True:

     inp = input('请输入要发送的内容：')

     if inp == 'q':

         obj.sendall(bytes(inp, encoding='utf-8'))

         break

     else:

         obj.sendall(bytes(inp, encoding='utf-8'))

         ret = str(obj.recv(1024), encoding='utf-8')

         print(ret)

 obj.close()

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 import select

 sk1 = socket.socket()

 sk1.bind(('127.0.0.2', 9000))

 sk1.listen()

 inputs = [sk1]

 outputs = []

 message_dict = {}

 while True:

     # r_list 中一开始只有服务器sk1，小军连接时，会把小军加入到inputs

     r_list, w_list, e_list = select.select(inputs, outputs, inputs, 1)

     # 1,是等待1秒的意思

     print('正在监听的socket对象%d' % len(inputs))

     print(r_list)

     for sk1_or_conn in r_list:

         # 每一个连接对象

         if sk1_or_conn == sk1:

             # 表示有新用户连接

             conn, address = sk1_or_conn.accept()

             inputs.append(conn)

             message_dict[conn] = []  # 建立了一个字典{小军：[]}

         else:

             try:   # 有老用户发消息了

                 data_bytes = sk1_or_conn.recv(1024)

             except Exception as ex:

                 inputs.remove(sk1_or_conn)

             else:

                 # 用户正常发消息

                 data_str = str(data_bytes, encoding='utf-8')

                 message_dict[sk1_or_conn].append(data_str)  # {小军：1233}

                 outputs.append(sk1_or_conn)  # [小军]

     # 谁发消息就会在w_list中显示。

     for conn in w_list:

         recv_str = message_dict[conn][0]

         del message_dict[conn][0]

         conn.sendall(bytes(recv_str + '好', encoding='utf-8'))

         outputs.remove(conn)

     for sk in e_list:

         inputs.remove(sk)

 #!/usr/bin/env python

 # -*- coding: utf-8 -*-

 import socket

 obj = socket.socket()

 obj.connect(('127.0.0.2', 9000))

 while True:

     inp = input('>>>>')

     obj.sendall(bytes(inp, encoding='utf-8'))

     ret = str(obj.recv(1024), encoding='utf-8')

     print(ret)

 obj.close()