python的socket

UDP

编程思路:
  udp服务器端:
  1.创建套接字(UDP);socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  2.绑定套接字到IP与端口;s.bind(('127.0.0.1', 9999))
  3.循环接收客户端数据(UDP是无连接,所以可以直接接收客户端发来的数据),并发送给对方数据;
  4.传输结束,关闭套接字。
  udp客户端:
  1.创建套接字,连接远端地址;socket.socket(socket.AF_INET, socket.SOCK_DGRAM
  2.连接后发送数据和接收数据;


服务器代码
import socket

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 绑定端口:
s.bind(('127.0.0.1', 9999))
print('Bind UDP on 9999...')
while True:
    # 接收数据:
    data, addr = s.recvfrom(1024)
    print('Received from %s:%s.' % addr)
    s.sendto(b'Hello, %s!' % data, addr)

注释:
      1.    创建Socket时,SOCK_DGRAM指定了这个Socket的类型是UDP。绑定端口和TCP一样,但是不需要调用listen()方法,而是直接接收来自任何客户端的数据。
      2.    s.recvfrom(bufsize[.flag])
    接受UDP套接字的数据。与recv()类似,但返回值是(data,address)。其中data是包含接收数据的字符串,address是发送数据的套接字地址。
      3.    s.sendto(string[,flag],address)
    发送UDP数据。将数据发送到套接字,address是形式为(ipaddr,port)的元组,指定远程地址。返回值是发送的字节数。


客户端代码:
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
for data in [b'Michael', b'Tracy', b'Sarah']:
    # 发送数据:
    s.sendto(data, ('127.0.0.1', 9999))
    # 接收数据:
    print(s.recv(1024).decode('utf-8'))
s.close()

总结:UDP的使用与TCP类似,但是不需要建立连接。此外,服务器绑定UDP端口和TCP端口互不冲突,也就是说,UDP的9999端口与TCP的9999端口可以各自绑定。




TCP

编程思路:

  TCP服务端:

  1.创建套接字,绑定套接字到本地IP与端口;
     # socket.socket(socket.AF_INET,socket.SOCK_STREAM) , s.bind()

  2. 开始监听连接;                   #s.listen()

  3. 进入循环,不断接受客户端的连接请求;              #s.accept()

  4. 然后接收传来的数据,并发送给对方数据;         #s.recv() , s.sendall()

  5. 传输完毕后,关闭套接字;                     #s.close();


  TCP客户端:

  1. 创建套接字,连接远端地址;

         # socket.socket(socket.AF_INET,socket.SOCK_STREAM) , s.connect()

  2. 连接后发送数据和接收数据;          # s.sendall(), s.recv()

  3. 传输完毕后,关闭套接字;          #s.close()


服务器代码:
def tcplink(sock, addr):
    print('Accept new connection from %s:%s...' % addr)
    sock.send(b'Welcome!')
    while True:
        data = sock.recv(1024)
        time.sleep(1)
        if not data or data.decode('utf-8') == 'exit':
            break
        sock.send(('Hello, %s!' % data.decode('utf-8')).encode('utf-8'))
    sock.close()
    print('Connection from %s:%s closed.' % addr)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 监听端口:
s.bind(('127.0.0.1', 9999))
s.listen(5)
print('Waiting for connection...')
while True:
    # 接受一个新的TCP连接并返回连接:
    sock, addr = s.accept()
    # 创建新线程来处理TCP连接:
    t = threading.Thread(target=tcplink, args=(sock, addr))
    t.start()

客户端代码:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 建立连接:
s.connect(('127.0.0.1', 9999))
# 接收欢迎消息:
print(s.recv(1024).decode('utf-8'))
for data in [b'Michael', b'Tracy', b'Sarah']:
    # 发送数据:
    s.send(data)
    print(s.recv(1024).decode('utf-8'))
s.send(b'exit')
s.close()

注释:

  1.s.accept()   接受TCP连接并返回(conn,address),其中conn是新的套接字对象,可以用来接收和发送数据。address是连接客户端的地址;

  2.s.listen(backlog)   开始监听TCP传入连接。backlog指定在拒绝连接之前,操作系统可以挂起的最大连接数量。该值至少为1,大部分应用程序设为5就可以了;

  3.s.recv(bufsize[,flag])   接受TCP套接字的数据。数据以字符串形式返回,bufsize指定要接收的最大数据量。flag提供有关消息的其他信息,通常可以忽略。

原文地址:https://www.cnblogs.com/Downtime/p/8461818.html