Socket编程

简介: Socket编程

Socket编程

1、socket_TCP网络通信

socket : 套接字,用来实现网络编程的一种数据传输手段  
socket把一些复杂的tcp/ip协议进行封装,我们就按部就班遵守socket规则进行编程
tcp协议:是传输可靠的数据通信协议(三次握手,四次挥手)
一般对于网络通信安全完整性比较高的时候:邮箱,传输文件,浏览网页,下载学习视频
udp协议:是传输不可靠的数据:会丢包
当实时性要求高到时候,直播,视频,语音
如何实现发送信息的网络通讯
1.手机(硬件接口)
2.发送信息
3.接受信息
4.关机
通讯步骤:
1.链接通畅
2.传输信息
3.关机链接
变成了python实现步骤
1.建立服务端socket 对象
2.绑定自己的ip(个人地址)以及端口号(动态端口号:1025-65535)
3.建立监听模式,设置最大的链接数
4.等待客户链接
5.接受客户端的数据/给客户端发送信息
6.关闭链接
客户端
1.创建客户端socket对象
2.链接服务端ip和端口
3.接收服务端数据/发送客户端信息
4.关闭
socket -->  connect  --> recv/send -> close
server.py
# socket 是内置函数,不需要下载
import socket
"""
socket 是套接字类, 有两个参数
socket_family :网络地址类型: ipv4参数值 -》 AF_INET af_inet
                            ipv6参数值 -》 AF_INET6 af_inet6
socket_type : 套接字 :TCP协议 =》 SOCK_STREAM sock_stream
                      UDP协议 => SOCK_DGRAM sock+dgram
"""
# 创建套接字对象
# 用ipv4,tcp协议的套接字
IPhone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定自己ip和端口号
# bind方法来实现,这里只有一个参数值,而且必须用元组传输
IPhone.bind(   ("127.0.0.1", 10086)   )
# 我们这里设置最大链接数
IPhone.listen(5)
# 等待客户端链接
"""
accept: 这个方法调用后会有两个返回值
    1. 客户端对象(数据),我们以后要用这个对象进行接受和发送
    2.客户端的ip和端口号
"""
# conn:就是客户端对象
# adder 地址:ip和端口
conn, adder = IPhone.accept()
# 接受和发送
# 接受数据:设定最大字节数,单位为b
data = conn.recv(1024)
# 我们数据:在网路中数据是以数据流传输
# 我们需要编译为文档文字, decode是字符串的编译
print(data.decode("utf-8"))
# 发送信息
data = input("》》》")
conn.send(data.encode("utf-8"))
conn.close()
IPhone.close()
huxing.py
import socket
# 建立客户端的对象
huxing = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定是服务端ip和端口
huxing.connect( ("127.0.0.1", 10086) )
data = input("》》》")
huxing.send(data.encode("utf-8"))
# 这里设置数据接受的最大字节数
data = huxing.recv(1024)
print(data.decode("utf-8"))
huxing.close()
添加循环通信
server.py
# socket 是内置函数,不需要下载
import socket
"""
socket 是套接字类, 有两个参数
socket_family :网络地址类型: ipv4参数值 -》 AF_INET
                            ipv6参数值 -》 AF_INET6
socket_type : 套接字 :TCP协议 =》 SOCK_STREAM 
                      UDP协议 => SOCK_DGRAM
"""
# 创建套接字对象
# 用ipv4,tcp协议的套接字
IPhone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定自己ip和端口号
# bind方法来实现,这里只有一个参数值,而且必须用元组传输
IPhone.bind(   ("127.0.0.1", 10086)   )
# 我们这里设置最大链接数
IPhone.listen(5)
# 等待客户端链接
"""
accept: 这个方法调用后会有两个返回值
    1. 客户端对象(数据),我们以后要用这个对象进行接受和发送
    2.客户端的ip和端口号
"""
# conn:就是客户端对象
# adder 地址:ip和端口
conn, adder = IPhone.accept()
while 1:
        # 接受和发送
        # 接受数据:设定最大字节数,单位为b
        # 会有链接出错
    try:
        data = conn.recv(1024)
        # 我们数据:在网路中数据是以数据流传输
        # 我们需要编译为文档文字, decode是字符串的编译
        print(data.decode("utf-8"))
        # 发送信息
        data = input("》》》")
        conn.send(data.encode("utf-8"))
    except ConnectionResetError as massg:
        print(massg)
        break
conn.close()
IPhone.close()
huxing.py
import socket
# 建立客户端的对象
huxing = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定是服务端ip和端口
huxing.connect(  ("127.0.0.1", 10086)  )
while 1:
        data = input("》》》")
        huxing.send(data.encode("utf-8"))
        if data == "晚安":
            break
        if not data:
            continue
        # 这里设置数据接受的最大字节数
        data = huxing.recv(1024)
        print(data.decode("utf-8"))
huxing.close()

2、socket_UDP网络通信

服务端:
1.创建服务端socket对象
2.绑定自己的ip和端口
3.接收客户端数据/发送数据
4.关闭链接
socket --》 bind -》》 recvfrom(收)/sendto(发) - 》close
客户端:
1.创建客户端socket对象
2.发送数据,接受数据
3.关闭
c/s
server.py
# socket 是内置函数,不需要下载
import socket
"""
socket 是套接字类, 有两个参数
socket_family :网络地址类型: ipv4参数值 -》 AF_INET
                            ipv6参数值 -》 AF_INET6
socket_type : 套接字 :TCP协议 =》 SOCK_STREAM 
                      UDP协议 => SOCK_DGRAM
"""
# 创建套接字对象
# 用ipv4,tcp协议的套接字
IPhone = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 绑定自己ip和端口号
# bind方法来实现,这里只有一个参数值,而且必须用元组传输
IPhone.bind(   ("127.0.0.1", 10086)   )
# 等待客户端链接
"""
accept: 这个方法调用后会有两个返回值
    1. 客户端对象(数据),我们以后要用这个对象进行接受和发送
    2.客户端的ip和端口号
"""
while 1:
        # 接受和发送
        # 接受数据:设定最大字节数,单位为b
        # 会有链接出错
    try:
        """
            UDP不需要额外建立链接,只需要发送成功就可以建立链接
            recvfrom : 也要最大字节数
            
            1.客户端数据包
            2.客户端ip和端口
            
        
        """
        # 我们数据:在网路中数据是以数据流传输
        # 我们需要编译为文档文字, decode是字符串的编译
        data, adder = IPhone.recvfrom(1024)
        print(data.decode("utf-8"))
        # 发送信息
        data = input("》》》")
        IPhone.sendto(data.encode("utf-8"), adder)
    except ConnectionResetError as massg:
        print(massg)
        break
IPhone.close()
huxing.py
import socket
# 建立客户端的对象
huxing = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 绑定是服务端ip和端口
ipPort = ("127.0.0.1", 10086)
while 1:
        data = input("》》》")
        huxing.sendto(data.encode("utf-8"), ipPort)
        if data == "晚安":
            break
        if not data:
            continue
        # 这里设置数据接受的最大字节数
        data, adder = huxing.recvfrom(1024)
        print(data.decode("utf-8"))
huxing.close()

3、socket响应网页(了解)

网页响应需要遵守http协议
如果不遵守就无法识别人响应(返回)信息
那么http协议格式需要我们来编写
客户端接受数据格式:
  响应格式:
  1.响应首行(http版本, 响应状态码) HTTP1.1  200 表示响应成功 ] \r\n
  2.响应头(一大堆键值对)一般写服务器版本号,开发组,、、、、、 \r\n
  3.空白行 \r\n
  4.响应体 (需要返回给浏览器看的数据 (前端数据))
  
  请求格式:
  1.请求首行(表示http版本号, 数据请求方式(get,post))
  2.请求头,可写可不写
  3.请求体
  
  
静态服务器
  
b/s
server.py
import socket
if __name__ == '__main__':
    tcpServerSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 需要设置端口复用(循环使用),程序检测到关闭自动端口号
    tcpServerSocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    # 绑定端口号
    # "" 默认本机地址
    tcpServerSocket.bind(("", 8848))
    tcpServerSocket.listen(128)
    while 1:
        try:
            newSocket, adder = tcpServerSocket.accept()
            data = newSocket.recv(4096)
            print(data)
            # 设置响应包
            # 响应行
            # http 1.1 是http协议版本, 200 ok 是状态码和说明信息
            responseLine = "HTTP/1.1 200 ok \r\n"
            # 响应头, 可以编写服务器版本
            responseHeader = "server:ziliangfuwuqi/1.0 \r\n"
            # 响应体 数据包
            with open(r"ziliang.html", "r", encoding="utf-8") as f:
                responseBody = f.read()
            # 把上面的响应行,响应头,响应体三者合一,变成报文
            response = responseLine+responseHeader+"\r\n"+responseBody
            # 组装好必须转换为二进制
            responseData = response.encode("utf-8")
            newSocket.send(responseData)
            newSocket.close()
        except Exception as e:
            print(e)
      break


相关文章
|
22天前
|
缓存 监控 Java
Java Socket编程最佳实践:优化客户端-服务器通信性能
【6月更文挑战第21天】Java Socket编程优化涉及识别性能瓶颈,如网络延迟和CPU计算。使用非阻塞I/O(NIO)和多路复用技术提升并发处理能力,减少线程上下文切换。缓存利用可减少I/O操作,异步I/O(AIO)进一步提高效率。持续监控系统性能是关键。通过实践这些策略,开发者能构建高效稳定的通信系统。
|
22天前
|
Java 应用服务中间件 开发者
【实战指南】Java Socket编程:构建高效的客户端-服务器通信
【6月更文挑战第21天】Java Socket编程用于构建客户端-服务器通信。`Socket`和`ServerSocket`类分别处理两端的连接。实战案例展示了一个简单的聊天应用,服务器监听端口,接收客户端连接,并使用多线程处理每个客户端消息。客户端连接服务器,发送并接收消息。了解这些基础,加上错误处理和优化,能帮你开始构建高效网络应用。
|
22天前
|
IDE Java 开发工具
从零开始学Java Socket编程:客户端与服务器通信实战
【6月更文挑战第21天】Java Socket编程教程带你从零开始构建简单的客户端-服务器通信。安装JDK后,在命令行分别运行`SimpleServer`和`SimpleClient`。服务器监听端口,接收并回显客户端消息;客户端连接服务器,发送“Hello, Server!”并显示服务器响应。这是网络通信基础,为更复杂的网络应用打下基础。开始你的Socket编程之旅吧!
|
22天前
|
Java
Java Socket编程与多线程:提升客户端-服务器通信的并发性能
【6月更文挑战第21天】Java网络编程中,Socket结合多线程提升并发性能,服务器对每个客户端连接启动新线程处理,如示例所示,实现每个客户端的独立操作。多线程利用多核处理器能力,避免串行等待,提升响应速度。防止死锁需减少共享资源,统一锁定顺序,使用超时和重试策略。使用synchronized、ReentrantLock等维持数据一致性。多线程带来性能提升的同时,也伴随复杂性和挑战。
|
22天前
|
安全 Java 网络安全
Java Socket编程教程:构建安全可靠的客户端-服务器通信
【6月更文挑战第21天】构建安全的Java Socket通信涉及SSL/TLS加密、异常处理和重连策略。示例中,`SecureServer`使用SSLServerSocketFactory创建加密连接,而`ReliableClient`展示异常捕获与自动重连。理解安全意识,如防数据截获和中间人攻击,是首要步骤。通过良好的编程实践,确保网络应用在复杂环境中稳定且安全。
|
5天前
|
网络协议 安全 Java
Java中的网络编程:Socket编程详解
Java中的网络编程:Socket编程详解
|
8天前
|
Java API 开发者
Java中的Socket编程与应用
Java中的Socket编程与应用
|
10天前
|
网络协议 安全 Java
Java中的网络编程:Socket编程详解
Java中的网络编程:Socket编程详解
|
10天前
|
Java API 开发者
Java中的Socket编程与应用
Java中的Socket编程与应用
|
12天前
|
监控 Java API
Java Socket编程入门
Java Socket编程入门