当前位置: 首页 > news >正文

socket是如何进行通信的

Socket通信的原理大致分为以下几个步骤:

  1. 服务器端建立Socket,开始侦听整个网络中的连接请求。
  2. 当检测到来自客户端的连接请求时,向客户端发送收到连接请求的信息,并建立与客户端之间的连接。
  3. 当完成通信后,服务器关闭与客户端的Socket连接。

客户端的步骤如下:

  1. 建立客户端的Socket,确定要连接的服务器的主机名和端口。
  2. 发送连接请求到服务器,并等待服务器的回馈信息。
  3. 连接成功后,与服务器进行数据的交互。
  4. 数据处理完毕后,关闭自身的Socket连接。
    Socket通信的基本原理是基于TCP/IP协议栈的。简单来说,Socket是网络中的一种端点,客户端通过Socket与服务器进行连接和通信。

下面是一个简单的TCP Socket通信的Python代码示例:

python
# 服务器端代码
import socket# 创建一个socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 绑定IP地址和端口号
server_address = ('localhost', 8000)
server_socket.bind(server_address)# 开始监听连接请求
server_socket.listen(1)
print('服务器已启动,等待客户端连接...')# 等待客户端连接
client_socket, client_address = server_socket.accept()
print(f'客户端{client_address}已连接')# 接收客户端发送的数据
data = client_socket.recv(1024)
print(f'收到客户端发送的数据:{data}')# 向客户端发送响应数据
response = '你好,客户端!'
client_socket.send(response.encode())# 关闭连接
client_socket.close()
server_socket.close()
客户端代码:python
import socket# 创建一个socket对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 连接服务器,指定IP地址和端口号
server_address = ('localhost', 8000)
client_socket.connect(server_address)# 向服务器发送数据
message = '你好,服务器!'
client_socket.send(message.encode())# 接收服务器的响应数据
response = client_socket.recv(1024)
print(f'收到服务器的响应:{response}')# 关闭连接
client_socket.close()

这个示例中,服务器端首先创建一个Socket对象,并绑定到指定的IP地址和端口号上。然后,它开始监听来自客户端的连接请求。当有客户端请求连接时,服务器接受连接请求,并与客户端进行通信。在通信过程中,客户端向服务器发送数据,服务器接收数据并返回响应。最后,双方都关闭连接。

以下是一个简单的C语言Socket通信代码示例:

服务器端代码:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>#define PORT 8000int main() {int server_socket, client_socket;struct sockaddr_in server_addr, client_addr;char buffer[1024];int bytes_read;// 创建socket对象server_socket = socket(AF_INET, SOCK_STREAM, 0);if (server_socket == -1) {perror("socket error");exit(1);}// 绑定IP地址和端口号memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htonl(INADDR_ANY);server_addr.sin_port = htons(PORT);if (bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {perror("bind error");exit(1);}// 开始监听连接请求if (listen(server_socket, 1) == -1) {perror("listen error");exit(1);}// 等待客户端连接socklen_t client_addr_len = sizeof(client_addr);client_socket = accept(server_socket, (struct sockaddr *)&client_addr, &client_addr_len);if (client_socket == -1) {perror("accept error");exit(1);}// 接收客户端发送的数据并输出到控制台bytes_read = recv(client_socket, buffer, sizeof(buffer), 0);if (bytes_read > 0) {buffer[bytes_read] = '\0';printf("收到客户端发送的数据:%s\n", buffer);} else {perror("recv error");exit(1);}// 向客户端发送响应数据并关闭连接const char *response = "你好,客户端!";send(client_socket, response, strlen(response), 0);close(client_socket);close(server_socket);return 0;
}

客户端代码示例:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>#define PORT 8000
#define SERVER "localhost"int main() {int client_socket;struct sockaddr_in server_addr;char buffer[1024];int bytes_read;// 创建socket对象client_socket = socket(AF_INET, SOCK_STREAM, 0);if (client_socket == -1) {perror("socket error");exit(1);}// 连接服务器,指定IP地址和端口号memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = inet_addr(SERVER); // 将主机名转换为IP地址server_addr.sin_port = htons(PORT); // 将端口号转换为网络字节序if (connect(client_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {perror("connect error");exit(1);}// 向服务器发送数据并等待响应const char *message = "你好,服务器!";send(client_socket, message, strlen(message), 0);bytes_read = recv(client_socket, buffer, sizeof(buffer), 0);if (bytes_read > 0) {buffer[bytes_read] = '\0';printf("收到服务器的响应:%s\n", buffer);} else {perror("recv error");exit(1);}// 关闭连接close(client_socket);return 0;
}
http://www.lryc.cn/news/259647.html

相关文章:

  • STM32-固件打包部署
  • 微信机器人如何使用?好用吗?好奇
  • ARMV8 - A64 - 函数调用,内存栈操作
  • MyBatis 四大核心组件之 ResultSetHandler 源码解析
  • docker-compose 单机容器编排
  • springboot项目使用Layui作为前端UI的一系列前后端交互的解决方法
  • 【Linux】Firewalld防火墙新增端口、开启、查看等
  • 学习笔记 -- TVS管选型参考
  • 功能更新|免费敏捷工具Leangoo领歌私有部署新增第三方身份认证和API对接
  • 重生奇迹mu战士加点
  • 【数据结构(十一·多路查找树)】B树、B+树、B*树(6)
  • 弟弟的作业
  • 代码随想录算法训练营第37天|● 738.单调递增的数字 ● 968.监控二叉树 ● 总结
  • 出现 java: 找不到符号 符号: 变量 log 的解决方法
  • 大数据机器学习与深度学习—— 生成对抗网络(GAN)
  • vue前端访问Django channels WebSocket失败
  • 厉害了!水浸监控技术有升级啦
  • 【开题报告】基于SpringBoot的大学生心理教育平台的设计与实现
  • 376. 摆动序列
  • 现在个人想上架微信小游戏已经这么难了吗...
  • C语言数据结构-----二叉树(2)堆的深入理解及应用、链式二叉树的讲解及代码实现
  • 【算法】【动规】等差数列划分
  • 系统架构设计师教程(五)软件工程基础知识
  • 计算机中的文件管理
  • Linux常见排错思路及命令
  • 【springboot】【easyexcel】excel文件读取
  • 【STM32】ADC模数转换器
  • Git篇---第九篇
  • Paper Reading: (ACRST) 基于自适应类再平衡自训练的半监督目标检测
  • 2023年贺岁电影:一眼多,二眼好多