021——搭建TCP网络通信环境（c服务器python客户端）

2024-04-11 02:44
文章标签 python 服务器 搭建 环境 客户端 tcp 网络通信 021

本文主要是介绍021——搭建TCP网络通信环境（c服务器python客户端），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

前言

服务器程序

服务器程序验证过程

客户端程序

前言

        驱动开发暂时告一段落了。后面在研究一下OLED和GPS的驱动开发，并且优化前面已经移植过来的这些驱动，我的理念是在封装个逻辑处理层来处理这些驱动程序。server直接操作逻辑处理层的程序。

        这次服务器的开发也不会一步到位，先做最简单的然后在逐渐迭代。

服务器程序

/*  * 文件名: server.c  * 作者: 辛天宇  * 更新时间: 2024-04-10  * 软件版本号: 0.0.0  */
/**************************************************************
***************************INCLUDE*****************************
**************************************************************/
#include "net.h"
/**************************************************************
****************************LOCAL******************************
**************************************************************/
void cli_data_handle (void *arg);
int main()
{int fd = -1;struct sockaddr_in sin;//创建socket fd*if((fd = socket(AF_INET,SOCK_STREAM, 0)) < 0){perror("socket");//return -1;exit(1);}/*优化4： 允许绑定地址快速重用 */int b_reuse = 1;setsockopt (fd, SOL_SOCKET, SO_REUSEADDR, &b_reuse, sizeof (int));//绑定//填充struct socketddr_in结构体变量bzero(&sin,sizeof(sin));//把sin全填充0sin.sin_family = AF_INET;//地址族网际网区域sin.sin_port = htons(SERV_PORT); //网络字节端口号//优化使server可以绑定在任意IP上
#if 1sin.sin_addr.s_addr = htonl(INADDR_ANY);//INADDY_ANY = -1
#elseif( inet_pton(AF_INET,SERV_IP_ADDR,(void *)&sin.sin_addr) != 1){perror("inet_pton");exit(1);		}
#endif//绑定if(bind(fd, (struct sockaddr *)&sin, sizeof(sin)) < 0) {perror("bind");exit(1);}//调用listen()把主动套接字变成被动套接字if(listen(fd,BACKLOG) < 0 ){perror("listen");exit(1);}printf("Server starting...OK!\n");int newfd = -1;//阻塞等待客户端连接
#if 0newfd = accept(fd, NULL, NULL);if(newfd < 0){perror("accept");exit(1);}
#else
//通过程序获取刚建立连接的socket客户端的ip地址和端口号pthread_t tid;struct sockaddr_in cin;socklen_t addrlen = sizeof (cin);while (1) {if ((newfd = accept (fd, (struct sockaddr *) &cin, &addrlen)) < 0) {perror ("accept");exit (1);}char ipv4_addr[16];if (!inet_ntop (AF_INET, (void *) &cin.sin_addr, ipv4_addr, sizeof (cin))) {perror ("inet_ntop");exit (1);}printf ("Clinet(%s:%d) is connected!\n", ipv4_addr, htons (cin.sin_port));pthread_create (&tid, NULL, (void *) cli_data_handle, (void *) &newfd);}close (fd);return 0;
}
#endif
void cli_data_handle (void *arg)
{int newfd = *(int *) arg;printf ("handler thread: newfd =%d\n", newfd);//..和newfd进行数据读写int ret = -1;char buf[BUFSIZ];while (1) {bzero (buf, BUFSIZ);do {ret = read (newfd, buf, BUFSIZ - 1);} while (ret < 0 && EINTR == errno);if (ret < 0) {perror ("read");exit (1);}if (!ret) {				//对方已经关闭break;}printf ("Receive data: %s\n", buf);if (!strncasecmp (buf, QUIT_STR, strlen (QUIT_STR))) {	//用户输入了quit字符printf ("Client(fd=%d) is exiting!\n", newfd);break;}}close (newfd);}

这是以前学网络编程的时候写的拿过来改一改

稍微改一下

/*
*author   : xintianyu
*function : main
*data     : 2024-4-10
-----------------------
*author : ???
*return : ???
*data   : ???
*/
int main(int argc, char *argv[])
{if(ERROR == usage(argc, argv))return 0;tcp_server(argc, argv);return 0;
}
/*
*author : xintianyu
*return : err num
*data   : 2024-4-10
-----------------------
*author : ???
*return : ???
*data   : ???
*/
int usage(int argc, char *argv[])
{ if (argc != 3){  printf("Usage: %s <ip_address> <port>\n", argv[0]);  return ERROR;  }else{return NOERROR;}
}
/*
*author : xintianyu
*return : err num
*data   : 2024-4-10
-----------------------
*author : ???
*return : ???
*data   : ???
*/
int tcp_server(int argc, char *argv[]) 
{int server_fd, client_fd;  struct sockaddr_in server_addr, client_addr;  socklen_t client_len = sizeof(client_addr);  char buffer[BUFFER_SIZE];  char *ip_address = argv[1];  int port = atoi(argv[2]);  // 创建TCP套接字  if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {  perror("socket creation failed");  exit(EXIT_FAILURE);  }  // 设置服务器地址信息  memset(&server_addr, 0, sizeof(server_addr));  server_addr.sin_family = AF_INET;  server_addr.sin_addr.s_addr = inet_addr(ip_address);  server_addr.sin_port = htons(port);  // 绑定套接字到服务器地址  if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {  perror("bind failed");  exit(EXIT_FAILURE);  }  // 监听套接字  if (listen(server_fd, 5) < 0) {  perror("listen failed");  exit(EXIT_FAILURE);  }  printf("Server listening on %s:%d...\n", ip_address, port);  while (1) {  // 接受客户端连接  if ((client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_len)) < 0) {  perror("accept failed");  continue;  }  // 打印客户端信息  char client_ip[INET_ADDRSTRLEN];  inet_ntop(AF_INET, &client_addr.sin_addr, client_ip, INET_ADDRSTRLEN);  printf("Client connected from %s:%d\n", client_ip, ntohs(client_addr.sin_port));  // 接收客户端消息  memset(buffer, 0, BUFFER_SIZE);  ssize_t bytes_read = recv(client_fd, buffer, BUFFER_SIZE - 1, 0);  if (bytes_read < 0) {  perror("recv failed");  close(client_fd);  continue;  }  // 确保消息以换行符结尾，并打印接收到的消息  if (bytes_read > 0 && buffer[bytes_read - 1] != '\n') {  buffer[bytes_read] = '\n';  buffer[bytes_read + 1] = '\0';  }  printf("Received message: %s", buffer);  // 回复客户端消息  strcpy(buffer, "Hello, client!\n");  if (send(client_fd, buffer, strlen(buffer), 0) < 0) {  perror("send failed");  }  close(client_fd);  }close(server_fd);return NOERROR;  
}

写的比较简单因为没有业务逻辑暂时只是验证通信问题。

服务器程序验证过程

编译命令

这是我们现在的目录结构

客户端程序

import socketserver_ip   = '192.168.5.110'
server_port = 8888 # 设置服务器地址和端口  
server_address = (server_ip, server_port)
# 创建一个socket对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 连接到服务器  
client_socket.connect(server_address)  
try:  # 发送数据  message = 'Hello, server!'.encode()  print(f'Sending {message}')  client_socket.sendall(message)  # 接收数据  amount_received = 0  amount_expected = len(message)  while amount_received < amount_expected:  data = client_socket.recv(16)  amount_received += len(data)  print(f'Received {data}')  finally:  # 关闭连接  print('Closing socket')  client_socket.close()

一下就没了我优化一下让他可以一直通信

import socket  server_ip   = '192.168.5.110'
server_port = 8888 # 设置服务器地址和端口  
server_address = (server_ip, server_port)# 创建一个socket对象  
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 连接到服务器  
try:  client_socket.connect(server_address)  print(f'Connected to {server_address}')  # 接收用户输入并发送给服务器  while True:  try:  user_input = input('Enter command (or "exit" to quit): ')  if user_input.lower() == 'exit':  break  client_socket.sendall(user_input.encode())  # 接收服务器的响应  data = client_socket.recv(1024)  print(f'Received: {data.decode()}')  except KeyboardInterrupt:  print('\nKeyboardInterrupt received, exiting...')  break  except ConnectionResetError:  print('\nConnection reset by server, exiting...')  break  except Exception as e:  print(f'An error occurred: {e}, trying to reconnect...')  client_socket.close()  # Close the socket if there's an error  client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # Create a new one  client_socket.connect(server_address)  # Reconnect to the server  finally:  # 关闭连接  print('Closing socket')  client_socket.close()

有问题哇，只能发过去第一条

一顿debug发现是服务器的问题，现在算是通讯正常了。

服务器最新程序

int tcp_server(int argc, char *argv[]) 
{int server_fd, client_fd;  struct sockaddr_in server_addr, client_addr;  socklen_t client_len = sizeof(client_addr);  char buffer[BUFFER_SIZE];  char *ip_address = argv[1];  int port = atoi(argv[2]);  // 创建TCP套接字  if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {  perror("socket creation failed");  exit(EXIT_FAILURE);  }  // 设置服务器地址信息  memset(&server_addr, 0, sizeof(server_addr));  server_addr.sin_family = AF_INET;  server_addr.sin_addr.s_addr = inet_addr(ip_address);  server_addr.sin_port = htons(port);  // 绑定套接字到服务器地址  if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {  perror("bind failed");  exit(EXIT_FAILURE);  }  // 监听套接字  if (listen(server_fd, 5) < 0) {  perror("listen failed");  exit(EXIT_FAILURE);  }  printf("Server listening on %s:%d...\n", ip_address, port);  // 接受客户端连接  if ((client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_len)) < 0) {  perror("accept failed");  }while (1) {// 打印客户端信息  char client_ip[INET_ADDRSTRLEN];  inet_ntop(AF_INET, &client_addr.sin_addr, client_ip, INET_ADDRSTRLEN);  printf("Client connected from %s:%d\n", client_ip, ntohs(client_addr.sin_port));  // 接收客户端消息  memset(buffer, 0, BUFFER_SIZE);  ssize_t bytes_read = recv(client_fd, buffer, BUFFER_SIZE - 1, 0);  if (bytes_read < 0) {  perror("recv failed");  close(client_fd);  continue;  }  // 确保消息以换行符结尾，并打印接收到的消息  if (bytes_read > 0 && buffer[bytes_read - 1] != '\n') {  buffer[bytes_read] = '\n';  buffer[bytes_read + 1] = '\0';  }  printf("Received message: %s", buffer);  // 回复客户端消息  strcpy(buffer, "Hello, client!\n");  if (send(client_fd, buffer, strlen(buffer), 0) < 0) {  perror("send failed");  }}close(client_fd); close(server_fd);return NOERROR;  
}

这篇关于021——搭建TCP网络通信环境（c服务器python客户端）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/892876。

相关文章

一篇文章彻底搞懂macOS如何决定java环境

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面：本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一：使用 which命令方法二：使用 Java_home工具（Apple 官方推荐）那问题来了，
阅读更多...
vite搭建vue3项目的搭建步骤

vite搭建vue3项目的搭建步骤

《vite搭建vue3项目的搭建步骤》本文主要介绍了vite搭建vue3项目的搭建步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录1.确保Nodejs环境2.使用vite-cli工具3.进入项目安装依赖1.确保Nodejs环境
阅读更多...
Python版本信息获取方法详解与实战

Python版本信息获取方法详解与实战

《Python版本信息获取方法详解与实战》在Python开发中,获取Python版本号是调试、兼容性检查和版本控制的重要基础操作,本文详细介绍了如何使用sys和platform模块获取Python的主... 目录1. python版本号获取基础2. 使用sys模块获取版本信息2.1 sys模块概述2.1.1
阅读更多...
Nginx搭建前端本地预览环境的完整步骤教学

Nginx搭建前端本地预览环境的完整步骤教学

《Nginx搭建前端本地预览环境的完整步骤教学》这篇文章主要为大家详细介绍了Nginx搭建前端本地预览环境的完整步骤教学,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录项目目录结构核心配置文件：nginx.conf脚本化操作：nginx.shnpm 脚本集成总结：对前端的意义很多
阅读更多...
一文详解Python如何开发游戏

一文详解Python如何开发游戏

《一文详解Python如何开发游戏》Python是一种非常流行的编程语言,也可以用来开发游戏模组,：本文主要介绍Python如何开发游戏的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下... 目录一、python简介二、Python 开发 2D 游戏的优劣势优势缺点三、Python 开发 3D
阅读更多...
Python函数作用域与闭包举例深度解析

Python函数作用域与闭包举例深度解析

《Python函数作用域与闭包举例深度解析》Python函数的作用域规则和闭包是编程中的关键概念,它们决定了变量的访问和生命周期,：本文主要介绍Python函数作用域与闭包的相关资料,文中通过代码... 目录1. 基础作用域访问示例1：访问全局变量示例2：访问外层函数变量2. 闭包基础示例3：简单闭包示例4
阅读更多...
Python实现字典转字符串的五种方法

Python实现字典转字符串的五种方法

《Python实现字典转字符串的五种方法》本文介绍了在Python中如何将字典数据结构转换为字符串格式的多种方法,首先可以通过内置的str()函数进行简单转换;其次利用ison.dumps()函数能够... 目录1、使用json模块的dumps方法：2、使用str方法：3、使用循环和字符串拼接：4、使用字符
阅读更多...
Python版本与package版本兼容性检查方法总结

Python版本与package版本兼容性检查方法总结

《Python版本与package版本兼容性检查方法总结》：本文主要介绍Python版本与package版本兼容性检查方法的相关资料,文中提供四种检查方法,分别是pip查询、conda管理、PyP... 目录引言为什么会出现兼容性问题方法一：用 pip 官方命令查询可用版本方法二：conda 管理包环境方法
阅读更多...
Linux云服务器手动配置DNS的方法步骤

Linux云服务器手动配置DNS的方法步骤

《Linux云服务器手动配置DNS的方法步骤》在Linux云服务器上手动配置DNS（域名系统）是确保服务器能够正常解析域名的重要步骤,以下是详细的配置方法,包括系统文件的修改和常见问题的解决方案,需要... 目录1. 为什么需要手动配置 DNS？2. 手动配置 DNS 的方法方法 1：修改 /etc/res
阅读更多...
基于Python开发Windows自动更新控制工具

基于Python开发Windows自动更新控制工具

《基于Python开发Windows自动更新控制工具》在当今数字化时代,操作系统更新已成为计算机维护的重要组成部分,本文介绍一款基于Python和PyQt5的Windows自动更新控制工具,有需要的可... 目录设计原理与技术实现系统架构概述数学建模工具界面完整代码实现技术深度分析多层级控制理论服务层控制注
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2