socket基本用法

socket介绍

1、什么是socket

  socket是应用层与传输层中间的一个软件抽象层,它是一组接口。它把TCP/IP这些复杂的协议统一封装起来

  这样我们只要知道如何使用socket就好,就已经符合了传输层往下的一大串协议

2、为什么要使用socket

  如果没有socket而我们写的代码又要让别人能正确解析,就需要一层层往下研究协议,写出符合协议的代码

  而我们大家传输层往下的代码基本一样,所以把这些代码封装成一个模块,方便大家使用,不用去考虑传输层

  以下的东西

3、socket发展

  套接字起源于20世纪70年代,一开始,套接字被设计用在同一台主机上多个应用程序的通讯,这也被称为

  进程间通讯或者IPC。后来网络发展,又被应用于网络协议上。

  套接字有两种(或者称为有两个种族):

    基于文件类型的套接字家族:名字  --> AF_UNIX

    基于网络类型的套接字家族:名字  --> AF_INET被用于ipv4       AF_INET6被用于ipv6

socket用法

# 需要明确的是:

  关于网络协议和socket相关概念,对于所有编程语言都是一致的,区别仅仅是个编程语言的函数名称不同

1、服务器端

import socket
# 获得socket对象 AF_INET表示基于网络的套接字
sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# SOCK_STREAM表示的是TCP协议  SOCK_DGRAM表示的是UDP协议
# 将socket对象绑定ip地址和端口号
sk.bind(('127.0.0.1',8080))     # 参数需要传入一个元组
# 相当于电话的开机 括号里的参数表示可以同时接收5个请求
sk.listen(5)

# 一般服务器都不需要关闭,所以加个while循环
while True:
# 进入监听状态,等待别人链接过来,有两个返回值,一个是对方的socket对象,一个是对方的ip以及端口
    client,addr = sk.accept()
    # 收发消息一般都需要多次循环发送,也加个while循环
    while True:
        try: # 如果对面强行关闭,为了程序不崩,就需要异常处理
            msg = client.recv(1024)    # recv表示接收,括号里是最大接收字节
            if not msg: # 如果接收到的消息是空字符串,就表示对面正常退出,需要打断循环
                break
            # send表示发送数据,发送的数据必须是二进制数据
            client.send('二进制数据'.encode('utf-8'))
        except Exception as e:
            print(e)
            break
    client.close()  # 关闭对面传过来的对象
sk.close()  # 关闭服务器的socket对象

2、客户端

import socket
# 获取socket对象,括号里默认是AF_INET  和 SOCK_STREAM  所以可以不写
sk = socket.socket()
# 链接到服务器端 括号里也是一个元组,包含ip地址以及对方的端口号
sk.connect(('127.0.0.1',8080))      # 自己的端口号系统会随机分配,不需要设置

while True: # 收发信息也需要循环
    try: # 为了防止服务器非正常下线而导致客户端直接崩溃,需要加入异常处理
        cmd = input('>>(q:退出)')
        if cmd == 'q':  # 给客户端一个可以正常退出的方法
            break
        if not cmd: # 如果直接敲回车,那么cmd就是空字符串,TCP协议对此进行优化
            continue    # 正常收发消息过程中,你传入空字符串,它不会帮你发送
        sk.send(cmd.encode('utf-8'))
# 如果上面没有做空判断,输入空会直接跳过send这步,这样客户端和服务器端都处于接收状态,卡住不动
        sk.recv(1024) 
    except Exception as e:
        print(e)
        break
sk.close() # 关闭socket对象

3、基于TCP的socket通讯流程图

socket常见问题

1、端口占用

报错信息

Traceback (most recent call last):
File "F:/pyprogram/day31/homework/topic2/test.py", line 6, in <module>
sk.bind(('127.0.0.1',8080))
OSError: [WinError 10048] 通常每个套接字地址(协议/网络地址/端口)只允许使用一次。

问题发生的原因

  1.可能是由于你已经启动了服务器程序,却又再次启动了服务器程序,同一个端口不能被多个进程使用导致

  2.三次握手或四次挥手时,发生了异常导致对方程序已经结束而服务器任然处于time_wait状态导致

  3.在高并发的场景下,由于连接的客户端太多,也会产生大量处于time_wait状态连接

解决的方案

  第一种重新选择端口后就可以,或者把之前的占用端口的进程关闭掉

  第二三种以后再说

2、强行关闭链接

报错信息

Traceback (most recent call last):
File "F:/pyprogram/day31/part2/客户端.py", line 12, in <module>
client.send(msg.encode('utf-8'))
ConnectionResetError: [WinError 10054] 远程主机强迫关闭了一个现有的连接。

问题发生的原因

  当客户端与服务器链接成功后,如果一方没有执行close,而是直接强行终止程序(或是遇到异常被迫终止)

  都会导致另一方发生问题

  在windows下,接收数据的一方在recv函数处将抛出异常

解决的方案

  用try...except语法抓取异常,抓到对方强退异常后并处理

3、客户端正常结束,服务器端无限循环空字符

报错信息

  不会产生报错信息,但是服务器端会一直循环空字符串

问题发生的原因

  客户端正常close()之后,会给服务器发送一个空字符串,

  如果服务器端没有发送数据的话,就会一直循环接收这个空字符串,占用CPU资源

解决的方案

  在服务器端接收的地方加上空字符串判断,如果是空字符串,就表示对方客户端退出了

  那么判断空成功,让自己也退出循环

原文地址:https://www.cnblogs.com/hesujian/p/10938420.html