提交tcp和udp编程的代码

Author: chengxianhuan

day-090/tcp-client.py

@@ -0,0 +1,36 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+@author: 闲欢
+"""
+
+import socket
+import time
+
+# 创建 socket
+s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+# 建立连接
+s.connect(("127.0.0.1", 6000))
+
+# 接收服务器消息
+print(s.recv(1024).decode())
+
+for data in [b'Michael', b'Tracy', b'Sarah']:
+    # 发送数据
+    s.send(data)
+    time.sleep(2)
+    # 打印接收到的数据
+    print(s.recv(1024).decode('utf-8'))
+    time.sleep(1)
+
+time.sleep(3)
+# 请求退出
+s.send(b'exit')
+time.sleep(2)
+print(s.recv(1024).decode('utf-8'))
+
+# 关闭连接
+s.close()
+
+

day-090/tcp-server.py

@@ -0,0 +1,46 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+@author: 闲欢
+"""
+
+import socket
+import threading
+import time
+
+
+# 处理tcp连接
+def tcplink(conn, addr):
+    print("Accept new connection from %s:%s" % addr)
+    # 向客户端发送欢迎消息
+    conn.send(b"Server: Welcome!\n")
+    while True:
+        conn.send(b"Server: What's your name?")
+
+        data = conn.recv(1024)
+        # 如果客户端发送 exit 过来请求退出，结束循环
+        if data == b"exit":
+            conn.send(b"Server: Good bye!\n")
+            break
+        conn.send(b"Server: Hello %s!\n" % data)
+
+    time.sleep(5)
+    # 关闭连接
+    conn.close()
+    print("Connection from %s:%s is closed" % addr)
+
+
+# 创建 socket
+s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+# 监听端口
+s.bind(("127.0.0.1", 6000))
+# 设定等待连接的最大数量为5
+s.listen(5)
+print("Waiting for connection...")
+# 等待接收连接
+while True:
+    # 接受一个新连接
+    conn, addr = s.accept()
+    # 创建新线程来处理TCP连接
+    t = threading.Thread(target=tcplink, args=(conn, addr))
+    t.start()

day-091/udp-client.py

@@ -0,0 +1,22 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+@author: 闲欢
+"""
+import socket
+
+# 创建 socket
+sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+addr = ('127.0.0.1', 6000)
+while True:
+    # 等待输入
+    msg = input('>>>')
+    # 发送数据报
+    sk.sendto(msg.encode('utf-8'), addr)
+    # 接收数据报
+    msg_recv, addr = sk.recvfrom(1024)
+    # 打印
+    print(msg_recv.decode('utf-8'))
+
+# 关闭 socket
+sk.close()

day-091/udp-server.py

@@ -0,0 +1,25 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+@author: 闲欢
+"""
+
+import socket
+
+# 创建 socket
+sk = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+# 绑定 IP 和端口号
+sk.bind(('127.0.0.1', 6000))
+while True:
+    # 接收数据报
+    msg, addr = sk.recvfrom(1024)
+    # 打印
+    print('来自[%s:%s]的消息: %s' % (addr[0], addr[1], msg.decode('utf-8')))
+
+    # 等待输入
+    inp = input('>>>')
+    # 发送数据报
+    sk.sendto(inp.encode('utf-8'), addr)
+
+# 关闭 socket
+sk.close()