首页 > 其他分享 >socket

socket

时间：2024-01-17 20:23:44浏览次数：21  
标签：socket send server client msg 接字

socke简介

  • 我们知道两个进程如果需要进行通讯最基本的一个前提能能够唯一的标示一个进程，在本地进程通讯中我们可以使用PID来唯一标识一个进程但PID只在本地唯一，网络中的两个进程PID冲突几率很大，这时候我们需要另辟它径了，我们知道IP层的ip地址可以唯一标示主机，而TCP层协议和端口号可以唯一标示主机的一个进程，

  • 这样我们可以利用ip地址＋协议＋端口号唯一标示网络中的一个进程。

  • 能够唯一标示网络中的进程后，它们就可以利用socket进行通信了，什么是socket呢？

  • 我们经常把socket翻译为套接字，socket是在应用层和传输层之间的一个抽象层，它把TCP/IP层复杂的操作抽象为几个简单的接口供应用层调用已实现进程在网络中通信。

img

  • socket起源于UNIX，在Unix一切皆文件哲学的思想下，socket是一种"打开—读/写—关闭"模式的实现，服务器和客户端各自维护一个"文件"，在建立连接打开后，可以向自己文件写入内容供对方读取或者读取对方内容，通讯结束时关闭文件。

(一)什么是socket

  • Socket是应用层与TCP/IP协议中通信的中间软件抽象层，它是一组接口。
    • 在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面
    • 对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。
  • 所以，我们无需深入理解tcp/udp协议，socket已经为我们封装好了，我们只需要遵循socket的规定去编程，写出的程序自然就是遵循tcp/udp标准的。
  • 也有人将socket说成ip+port
    • ip是用来标识互联网中的一台主机的位置
    • 而port是用来标识这台机器上的一个应用程序
    • ip地址是配置到网卡上的
    • 而port是应用程序开启的
    • ip与port的绑定就标识了互联网中独一无二的一个应用程序
  • 而程序的pid是同一台机器上不同进程或者线程的标识

（二）套接字发展史及分类

  • 套接字起源于 20 世纪 70 年代加利福尼亚大学伯克利分校版本的 Unix,即人们所说的 BSD Unix。
  • 因此,有时人们也把套接字称为“伯克利套接字”或“BSD 套接字”。
  • 一开始,套接字被设计用在同 一台主机上多个应用程序之间的通讯。
  • 这也被称进程间通讯,或 IPC。套接字有两种（或者称为有两个种族）,分别是
    • 基于文件型的
    • 基于网络型的

（1）基于文件类型的套接字家族

  • 套接字家族的名字：

    • AF_UNIX

  • unix一切皆文件

    • 基于文件的套接字调用的就是底层的文件系统来取数据
    • 两个套接字进程运行在同一机器
    • 可以通过访问同一个文件系统间接完成通信

（2）基于网络类型的套接字家族

  • 套接字家族名字

    • AF_INET

  • (还有AF_INET6被用于ipv6，还有一些其他的地址家族，不过，他们要么是只用于某个平台，要么就是已经被废弃，或者是很少被使用，或者是根本没有实现

    • 所有地址家族中，AF_INET是使用最广泛的一个
    • python支持很多种地址家族，但是由于我们只关心网络编程，所以大部分时候我么只使用AF_INET

（三）套接字工作流程

  • 一个生活中的场景。
    • 你要打电话给一个朋友，先拨号，朋友听到电话铃声后提起电话，这时你和你的朋友就建立起了连接，就可以讲话了。
    • 等交流结束，挂断电话结束此次交谈。 生活中的场景就解释了这工作原理。

img

服务端流程：

  • 先从服务器端说起。
    • 服务器端先初始化Socket
    • 然后与端口绑定(bind)，对端口进行监听(listen)
    • 调用accept阻塞，等待客户端连接。
    • 在这时如果有个客户端初始化一个Socket
    • 然后连接服务器(connect)
      • 如果连接成功，这时客户端与服务器端的连接就建立了。
    • 客户端发送数据请求，服务器端接收请求并处理请求
    • 然后把回应数据发送给客户端，客户端读取数据
    • 最后关闭连接，一次交互结束
  • socket()模块函数用法
  import socket
  socket.socket(socket_family,socket_type,protocal=0)
  socket_family 可以是 AF_UNIX 或 AF_INET。socket_type 可以是 SOCK_STREAM 或 SOCK_DGRAM。protocol 一般不填,默认值为 0。
  
 # 获取tcp/ip套接字
  tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  
 # 获取udp/ip套接字
  udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

 # 由于 socket 模块中有太多的属性。我们在这里破例使用了'from module import *'语句。使用 'from socket import *',我们就把 socket 模块里的所有属性都带到我们的命名空间里了,这样能 大幅减短我们的代码。
 #  例如tcpSock = socket(AF_INET, SOCK_STREAM

（1）服务端套接字函数

  • s.bind()绑定(主机，端口号)到套接字
  • s.listen()开始TCP监听
  • s.accept()被动接受TCP客户的连接，(阻塞式)等带连接的到来

（2）客户端套接字函数

  • s.coonect()主动初始化TCP服务器连接
  • s.connect_ex() connect()函数的扩展版本，出错时返回出错码，为不是抛出异常

（3）公共用途的套接字函数

  • s.recv()接收TCP数据
  • s.send()发送TCP数据（send在待发送数据量大于己端缓存区剩余空间时，数据丢失，不会发完）
  • s.sendall()发送完整的TCP数据（本质就是循环调用send,sendall在待发送数据量大于己端缓存区剩余空间时，数据不丢失，循环调用send直到发完）
  • s.recvfrom()接收UDP数据
  • s.sendto()发送UDP数据
  • s.getpeername()连接到当前套接字的远端的地址
  • s.getsockname()当前套接字的地址
  • s.getsockopt()返回指定套接字的参数
  • s.setsockopt()设置指定套接字的参数
  • s.close()关闭套接字

（4）面向所得套接字方法

  • s.setblocking()设置套接字的阻塞与非阻塞模式
  • s.settimeout()设置阻塞套接字操作的超时时间
  • s.gettimeout()得到阻塞套接字操作的超时时间

（5）面向文件的套接字的函数

  • s.fileno()套接字的文件描述符
  • s.makefile()创建一个与该套接字相关的文件

（四）基于TCP的套接字

（1）方法简介

  • tcp是基于链接的
    • 必须先启动服务端
    • 然后再启动客户端去链接服务端
  • tcp服务端
server = socket() #创建服务器套接字
server.bind()      #把地址绑定到套接字
server.listen()      #监听链接
inf_loop:      #服务器无限循环
    conn = server.accept() #接受客户端链接
    comm_loop:         #通讯循环
        conn.recv()/conn.send() #对话(接收与发送)
    conn.close()    #关闭客户端套接字
server.close()        #关闭服务器套接字(可选)
  • tcp客户端
client = socket()    # 创建客户套接字
client.connect()    # 尝试连接服务器
comm_loop:        # 通讯循环
    client.send()/client.recv()    # 对话(发送/接收)
client.close()            # 关闭客户套接字

（2）1.基础版本

  • client
# 导入模块
import socket
# 获取对象
client=socket.socket()
IP='127.0.0.1'
PORT=8080
# 绑定给套接字
client.connect((IP,PORT))
# 发送消息
send_msg=input("请输入发送的消息:").strip()
send_msg=send_msg.encode('utf-8')
client.send(send_msg)

# 接收消息
from_msg=client.recv(1024)
from_msg=from_msg.decode('utf-8')
print(from_msg)
# 关闭对象
client.close()
  • server
# 导入模块
import socket
# 获取对象
server=socket.socket()

# 获取IP和端口号
IP='127.0.0.1'
PORT=8080
# 将数据绑定给套接字
server.bind((IP,PORT))
# 监听
server.listen(5)

# 接收数据
conn,addr=server.accept()

# 接收消息
from_mgs=conn.recv(1024)
from_mgs=from_mgs.decode('utf-8')
print(from_mgs)

# 发送消息
send_msg=input("请输入发送的消息:").strip()
send_msg=send_msg.encode('utf-8')
conn.send(send_msg)
# 关闭套接字
conn.close()
# 关闭对象
server.close()

（3）2.循环版本

####################server
# 导入模块
import socket
# 获取对象
server=socket.socket()
# 获取IP地址和PORT端口号
IP='127.0.0.1'
PORT=9696
# 将数据绑定给套接字
server.bind((IP,PORT))
# 监听
server.listen(5)
while True:
    # 先接收
    conn,addr=server.accept()
    # 接收数据
    from_msg=conn.recv(1024)
    from_msg=from_msg.decode('utf-8')
    if from_msg=='q':
        conn.close()
        break
    print(from_msg)
    # 发送信息
    while True:
        send_msg=input("请输入发送的信息:").strip()
        if not send_msg:
            print("格式错误，请重新输入！！！")
            continue
        send_msg=send_msg.encode('utf-8')
        conn.send(send_msg)
        break
server.close()



##############client
# 导入模块
import socket
while True:
    # 获取对象
    client=socket.socket()
    # 获取IP地址和PORT端口号
    IP='127.0.0.1'
    PORT=9696
    # # 将数据绑定给套接字
    client.connect((IP,PORT))
    # 发送消息
    send_msg=input("请输入需要发送的消息:").strip()
    if not send_msg:
        print("输入格式有误，请重新输入！！！")
        continue
    client.send(send_msg.encode('utf-8'))
    if send_msg=='q':
        client.close()
        break


    # 接收消息
    from_msg=client.recv(1024)
    from_msg=from_msg.decode('utf-8')
    print(from_msg)

（五）基于UDP协议的简单套接字

（1）UDP协议

  • UDP协议--- 数据报协议

（2）空数据的处理

  • TCP协议时水流式协议：传入的数据不能为空，因为水是一直流的，在传输的过程中不会读数据进行操作
  • UDP协议是数据报协议：传入的数据可以为空，在传输过程中UDP会对数据进行内部的拼接和处理

（3）断开链接的影响

  • TCP协议是水流式协议：在建立链接过程中，服务端和客户端的链接是一直存在的，断开一方都会对另一方造成影响
  • UDP协议是数据报协议：在建立链接的过程中，是通过解析对方数据中的ip和端口，在向另一方返回数据的，所以一方发生问题不会影响到另一方

（4）模板

标签：socket,send,server,client,msg,接字
From： https://www.cnblogs.com/suyihang/p/17971081

相关文章

  • C# websocket服务端实现
    1、创建一个winform项目2、创建websocket服务端类WebSocket_Service.cs1usingSystem;2usingSystem.Collections.Generic;3usingSystem.ComponentModel;4usingSystem.Linq;5usingSystem.Net;6usingSystem.Net.Sockets;7usingSystem.Security......
  • Springboot3+Vue3在进行WebSocket通讯时出现No mapping for GET或者是404
    参考：在SpringBoot中整合、使用WebSocket-spring中文网(springdoc.cn)===============================原代码（此时前端访问后端，后端会出现：NomappingforGET/wspath）前端相关代码：letsocket:WebSocket|null=nullconstsocketURL=`ws://127.0.0.1:8084/w......
  • 网络编程之基于TCP协议的socket套接字编程
    基于TCP的套接字【1】方法简介tcp是基于链接的必须先启动服务端然后再启动客户端去链接服务端tcp服务端server=socket()#创建服务器套接字server.bind()#把地址绑定到套接字server.listen()#监听链接inf_loop:#服务器无限循环conn=serv......
  • 网络编程之Socket抽象层
    Socket介绍假设我们需要编写一个C/S架构的程序，实现数据交互，就需要使用到OSI七层协议，由于它的缺点是分层太多,增加了网络工作的复杂性，所以没有大规模应用。后来人们对OSI进行了简化，合并了一些层，最终只保留了4层，从下到上分别是接口层、网络层、传输层和应用层，这就是TCP/IP模......
  • 网络编程之基于UDP协议的socket套接字编程
    基于UDP的套接字udp是无链接的，先启动哪一端都不会报错【1】方法简介（1）UDP服务端server=socket()#创建一个服务器的套接字server.bind()#绑定服务器套接字inf_loop:#服务器无限循环conn=server.recvfrom()/conn.sendto()#对话(接收与发送)serv......
  • socket模块
    socket(1)scoket层在哪(2)什么是socketSocket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。所......
  • 【6.0】socketserver实现并发
    【一】引入socket并不能多并发，只能支持一个用户socketserver模块是Python中用于创建网络服务器的模块，提供了一种简单而一致的接口。它是构建网络服务器的框架，处理了创建、维护和关闭连接的许多底层细节socketserver是socket的再封装。【二】socketserver介绍【1】简......
  • docker jmeter分布式压测部署 jmeter websocket压测
    测试场景：1.多名用户加入房间。2.房间人数为固定人数（比如4人） 3.有人进入时，进入用户会收到反馈当前房间人员列表。4.其他人会收到反馈新加入用户的信息消息。5.当人数已满时，会自动推送消息给所有人。6.在人满后，每个人需要按固定序列，发送消息。7.所有人发送特定消息后，推进房......
  • JMeter测试WebSocket的经验总结
    最近有一个微信聊天系统的项目需要性能测试，既然是测试微信聊天，肯定绕不开websocket接口的测试，首选工具是Jmeter，网上能搜到现成的方法，但是网上提供的jar包往往不是最新的，既然是用最新版本的Jmeter4.0，那么所依赖的插件jar包也应该追求新的。所以提供了以下链接供大家下载（甚至连源码......
  • C# socket tcp/ip 如何判断连接是否正常
    判断socket是否断开连接，网上有N种说法：1.Socket.Connected这个属性只能说明上一次通信时还是正常的。比如说你拔掉网线后就它显示还是为true。用这个方法最好和ping一起组合使用。ping的方法如下publicboolPingOC(Stringips){boolret;Processp=newProcess();p.Start......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99