Python之路——网络编程

socket

TCP

服务端

import socket
sk = socket.socket()
sk.bind(('127.0.0.1',8080)) # 绑定ip和端口号
sk.listen() # Enable a server to accept connections.
conn,addr = sk.accept() # Wait for an incoming connection.  Return a new socket
                        # representing the connection, and the address of the client.
while 1:
    content = conn.recv(1024)   # 接收
    print(content.decode('utf-8'))
    conn.send(content+b'--liuyankui')   # 发送
conn.close()
sk.close()

客户端

import socket
sk = socket.socket()
sk.connect(('127.0.0.1',8080))  #连接
while 1:
    content = input('>>>').encode('utf-8')
    sk.send(content)
    ret = sk.recv(1024)
    print(ret.decode('utf-8'))
sk.close()

UDP

服务端

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1',8080))
msg ,addr = sk.recvfrom(1024)
print(msg.decode('utf-8'))
sk.sendto(b'bye',addr)
sk.close()

用户端

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
ip_port = ('127.0.0.1',8080)
sk.sendto(b'hello',ip_port)
msg,addr = sk.recvfrom(1024)
print(msg.decode('utf-8'))
sk.close()

 socketserver

server端

import socketserver

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            msg = self.request.recv(1024).decode('utf-8')
            if msg=='q':return
            print(msg)
            info = input('(sent to %s)>>>' %(msg[:2]))
            self.request.send(info.encode('utf-8'))
if __name__ == '__main__':
    server = socketserver.ThreadingTCPServer(('127.0.0.1',8080),MyServer)
    server.serve_forever()

client端

import socket
sk = socket.socket()
sk.connect(('127.0.0.1',8080))
while 1:
    msg = input('>>>')
    if msg == 'q':
        sk.send('q'.encode('utf-8'))
        break
    sk.send(('美团外卖:'+msg).encode('utf-8'))
    print(sk.recv(1024).decode('utf-8'))
sk.close()