Python socket服务常用操作代码实例

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):     # 通过类的继承，实现
  def handle(self):          # 重写父类的handle方法，所有的操作都在此方法中
    while True:           # 循环，不停的接收从客户端来的数据
      try:
        self.data = self.request.recv(1024).strip()     # 从客户端接收数据，每次收1024字节
        print("{} send:".format(self.client_address), self.data)
        self.request.send(self.data.upper())         # 从服务器发送给客户端数据
      except ConnectionResetError as e:
        print('Error: ',e)
        break

if __name__ == '__main__':
  host,port = 'localhost',9999
  server = socketserver.ThreadingTCPServer((host,port),MyTCPHandler)   # 通过多线程实现多个客户端连接，每个客户端连接都是一个线程
  server.serve_forever()                        # 一直运行服务

import socket

client = socket.socket()         # socket对象
client.connect(('localhost',9999))   # 连接服务器地址和端口

while True:               # 循环，不停的输入发送数据
  con = input('>>>:').strip()
  if len(con) ==0: continue      # 不能发送空数据，否则会阻塞
  client.send(con.encode('utf-8'))  # 发送数据，必须是二进制的
  data = client.recv(1024)      # 接收服务器返回的数据
  print(data.decode())        # 打印 解码后的数据

client.close()           # 关闭

import socket
import os
import threading

def tcplink(sock, addr):
  print('Accept new connection from %s:%s...' % addr)
  while True:     # 和每个接入的客户端，进行多次数据通信
    data = sock.recv(1024) # 接收客户端数据
    if not data or data.decode('utf-8') == 'exit': # 如果客户端不发送数据或者发送了exit
      print('client disconnected.')
      break
    content = os.popen(data.decode('utf-8')).read() # 对发送来的数据执行cmd命令，获取结果
    if len(content) == 0:      #如果执行的命令结果为空的，就手动造一个结果。因为如果为空数据，会挂起，无法正常发送。
      content = 'cmd not exists.'
    sock.send(str(len(content.encode('utf-8'))).encode('utf-8')) # 发送数据的长度
    print('send length:', (len(content.encode('utf-8'))))
    # print('content,', content.encode('utf-8'))
    recv = sock.recv(1024) # 因为上下都有一个send连在一起，可能发生粘包现象，为了防止这种情况，可以让客户端重新应答一下
    print('Answer:',recv.decode('utf-8'))
    sock.send(content.encode('utf-8'))    # 发送数据
    print('send finished.')
  sock.close()
  prin<a>本文来源gao($daima.com搞@代@#码8网^</a>t('Connection from %s:%s closed.' % addr)


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 监听端口:
s.bind(('127.0.0.1', 9999))
s.listen(3)
print('Waiting for connection...')

while True:
  # 接受一个新连接:
  sock, addr = s.accept()
  # 创建新线程来处理TCP连接:
  t = threading.Thread(target=tcplink, args=(sock, addr))
  t.start()

import socket

# AF_INET 代表ipv4，SOCK_STREAM 代表TCP
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)   # 确定网络协议，生成对象
s.connect(('127.0.0.1',9999)) # 连接服务器的地址和端口，元组的形式。
while True:
  msg = input('>>:').strip()
  if len(msg) != 0:         # 如果消息为空，会一直挂起，所以不能为空
    if msg =='exit':
      s.close()           # 关闭连接
      print('Connection closed.')
      break
    s.send(msg.encode('utf-8'))    # 给服务器发送数据，必须是二进制的
    length = s.recv(1024)      # 首先接收服务器返回的将要接收的数据的长度信息。
    s.send(b'Ready to receive...')  # 发送接收命令
    length = int(length.decode('utf-8'))
    print('receive len:', length)
    data_len = 0
    data_recv = b''
    while data_len < length:  # 已经接收的信息的长度，如果小于总长度
      data = s.recv(1024)   # 从服务器接收数据
      data_recv += data
      data_len += len(data)
    print(data_recv.decode('utf-8')) # 打印返回的数据。