[TOC]
## **一 最简单的C/S实现**
基于前面的打电话伪代码,实现服务器与客户端的单次通信
**server端代码**
```
import socket
#1、买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#2、绑定手机卡
phone.bind(('127.0.0.1',8081)) #元组形式的主机和端口
#3、开机
phone.listen(5) #允许5个连接排队
#4、等电话链接
print('starting...')
conn,client_addr=phone.accept() #接受的数据是一个元组
#5、收,发消息
data=conn.recv(1024) #1024代表最大接收1024个bytes
print('客户端的数据',data.decode('utf-8')) #接受的是bytes,需要转码
conn.send(data.upper())
#6、挂电话
conn.close()
#7、关机
phone.close()
```
**client端代码**
```
import socket
#1、买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#2、拨号
phone.connect(('127.0.0.1',8081))
#3、发,收消息
phone.send('hello'.encode('utf-8')) #只能发送bytes类型,所以要转码
data=phone.recv(1024)
print(data.decode('utf-8'))
#4、关闭
phone.close()
```
## **二 循环发送消息的实现**
上面的代码客户端和服务器断只能通信一次,然后就会断开连接,如果想多次发送数据,就需要加入循环语句
**server端代码**
```
import socket
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.bind(('127.0.0.1',8083))
phone.listen(5)
print('starting...')
conn,client_addr=phone.accept()
while True: #通信循环
data=conn.recv(1024)
print('客户端的数据',data)
conn.send(data.upper())
conn.close()
phone.close()
```
**client端代码**
```
import socket
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.connect(('127.0.0.1',8083))
while True: #通信循环
msg=input('>>: ').strip()
if not data:continue #避免发送空数据
phone.send(msg.encode('utf-8'))
data=phone.recv(1024)
print(data)
phone.close()
```
### **bug解释和修复**
上面的代码有2个bug,关于bug的说明和修改方式如下
1. client直接断开服务的话,server端会报错
修改server端的通信循环为如下样式,分别针对linux和windows服务器做不同的处理
```
while True: #通信循环
try:
data=conn.recv(1024)
if not data:break #适用于linux操作系统
print('客户端的数据',data)
conn.send(data.upper())
except ConnectionResetError: #适用于windows操作系统
break
```
2. 重启server端时可能提示端口占用
问题是由于服务端仍然存在四次挥手的time_wait状态在占用地址
解决方法1:socket方法
~~~
sock_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock_server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #写在bind前
sock_server.bind((HOST, PORT))
~~~
解决方法2:linux内核办法
`vi /etc/sysctl.conf`,在打开文件中加入以下内容:
net.ipv4.tcp_syncookies = 1
net.ipv4.tcp_tw_reuse = 1
net.ipv4.tcp_tw_recycle = 1
net.ipv4.tcp_fin_timeout = 30
然后执行 `/sbin/sysctl -p `让参数生效。
>net.ipv4.tcp_syncookies = 1 表示开启SYN Cookies。当出现SYN等待队列溢出时,启用cookies来处理,可防范少量SYN攻击,默认为0,表示关闭;
net.ipv4.tcp_tw_reuse = 1 表示开启重用。允许将TIME-WAIT sockets重新用于新的TCP连接,默认为0,表示关闭;
net.ipv4.tcp_tw_recycle = 1 表示开启TCP连接中TIME-WAIT sockets的快速回收,默认为0,表示关闭。
net.ipv4.tcp_fin_timeout 修改系統默认的 TIMEOUT 时间
## **循环建立连接的实现**
上面的C/S结构代码,仅能支持client与server一对一的通信,如果client断开连接也不会有新的客户端被接入,因此需要server段再建立连接处再加一层循环实现循环建立连接
**server端代码**
```
import socket
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
phone.bind(('127.0.0.1',8083)) #0-65535:0-1024给操作系统使用
phone.listen(5)
print('starting...')
while True: # 链接循环
conn,client_addr=phone.accept()
print(client_addr)
while True: #通信循环
try:
data=conn.recv(1024)
if not data:break #适用于linux操作系统
print('客户端的数据',data)
conn.send(data.upper())
except ConnectionResetError: #适用于windows操作系统
break
conn.close()
phone.close()
```
client端代码不需要任何改变
### **特别说明**
如上修改后,能实现多个客户端排队连接客户端进行通话的情况,但是实现不了多个客户端同时连接服务端通话的情况,需要用到后面的**并发编程**知识
- 基础部分
- 基础知识
- 变量
- 数据类型
- 数字与布尔详解
- 列表详解list
- 字符串详解str
- 元组详解tup
- 字典详解dict
- 集合详解set
- 运算符
- 流程控制与循环
- 字符编码
- 编的小程序
- 三级菜单
- 斐波那契数列
- 汉诺塔
- 文件操作
- 函数相关
- 函数基础知识
- 函数进阶知识
- lambda与map-filter-reduce
- 装饰器知识
- 生成器和迭代器
- 琢磨的小技巧
- 通过operator函数将字符串转换回运算符
- 目录规范
- 异常处理
- 常用模块
- 模块和包相关概念
- 绝对导入&相对导入
- pip使用第三方源
- time&datetime模块
- random随机数模块
- os 系统交互模块
- sys系统模块
- shutil复制&打包模块
- json&pickle&shelve模块
- xml序列化模块
- configparser配置模块
- hashlib哈希模块
- subprocess命令模块
- 日志logging模块基础
- 日志logging模块进阶
- 日志重复输出问题
- re正则表达式模块
- struct字节处理模块
- abc抽象类与多态模块
- requests与urllib网络访问模块
- 参数控制模块1-optparse-过时
- 参数控制模块2-argparse
- pymysql数据库模块
- requests网络请求模块
- 面向对象
- 面向对象相关概念
- 类与对象基础操作
- 继承-派生和组合
- 抽象类与接口
- 多态与鸭子类型
- 封装-隐藏与扩展性
- 绑定方法与非绑定方法
- 反射-字符串映射属性
- 类相关内置方法
- 元类自定义及单例模式
- 面向对象的软件开发
- 网络-并发编程
- 网络编程SOCKET
- socket简介和入门
- socket代码实例
- 粘包及粘包解决办法
- 基于UDP协议的socket
- 文件传输程序实战
- socketserver并发模块
- 多进程multiprocessing模块
- 进程理论知识
- 多进程与守护进程
- 锁-信号量-事件
- 队列与生产消费模型
- 进程池Pool
- 多线程threading模块
- 进程理论和GIL锁
- 死锁与递归锁
- 多线程与守护线程
- 定时器-条件-队列
- 线程池与进程池(新方法)
- 协程与IO模型
- 协程理论知识
- gevent与greenlet模块
- 5种网络IO模型
- 非阻塞与多路复用IO实现
- 带着目标学python
- Pycharm基本使用
- 爬虫
- 案例-爬mzitu美女
- 案例-爬小说
- beautifulsoup解析模块
- etree中的xpath解析模块
- 反爬对抗-普通验证码
- 反爬对抗-session登录
- 反爬对抗-代理池
- 爬虫技巧-线程池
- 爬虫对抗-图片懒加载
- selenium浏览器模拟