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

Linux TCP服务器客户端

服务器端

#include <sys/types.h>          
#include <sys/socket.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>

int main(int argc, char *argv[]){
    if(argc != 3){
        fprintf(stderr, "Usage: %s <IP> <Port>\n", argv[0]); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }

    struct sockaddr_in my_addr, oth_addr;
    ssize_t recv_data;
    char buf[250];

    int socket_ret = socket(AF_INET, SOCK_STREAM, 0);
    if(socket_ret < 0){
        perror("socket"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }

    memset(&my_addr, 0, sizeof(my_addr)); // 修正:使用memset替代bzero
    my_addr.sin_family = AF_INET;
    my_addr.sin_port = htons(atoi(argv[2])); // 注意:如果atoi(argv[2])结果过大,可能会溢出
    my_addr.sin_addr.s_addr = inet_addr(argv[1]); // 注意:如果argv[1]不是有效的IP地址,这里会返回INADDR_NONE

    if(bind(socket_ret, (const struct sockaddr *)&my_addr, sizeof(my_addr)) < 0){
        perror("bind"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }

    if(listen(socket_ret, 10) < 0){
        perror("listen"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);       
    }

    socklen_t len = sizeof(oth_addr);
    while(1){
        int client_socket = accept(socket_ret, (struct sockaddr *)&oth_addr, &len); // 修正:使用更明确的变量名

        if(client_socket < 0){
            perror("accept"); // 修正:提供完整的错误信息
            continue; // 修正:不退出程序,而是继续监听
        }

        printf("客户端地址为: %s\n", inet_ntoa(oth_addr.sin_addr)); // 修正:添加换行符\n

        memset(buf, 0, sizeof(buf)); // 修正:使用memset替代bzero
		while (1)
		{
		recv_data = recv(client_socket, buf, sizeof(buf) - 1, 0); // 修正:使用client_socket接收数据,并确保buf不会溢出
        if(recv_data > 0){
            printf("客户端发来:%s\n", buf); // 修正:添加换行符\n
        }

		}
		
      
        //close(client_socket); // 修正:关闭客户端套接字
    }

    // 注意:正常情况下,服务器套接字不应该在这里关闭,因为它需要持续监听新的连接
    // close(socket_ret); // 这行代码应该被注释掉或移除

    return 0;
}

客户端

#include <sys/types.h>          
#include <sys/socket.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>

int main(int argc, char *argv[]){
    if(argc != 3){
        fprintf(stderr, "Usage: %s <IP> <Port>\n", argv[0]); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }

    struct sockaddr_in my_addr, oth_addr;
    ssize_t recv_data;
    char buf[250];

    int socket_ret = socket(AF_INET, SOCK_STREAM, 0);
    if(socket_ret < 0){
        perror("socket"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }

    memset(&my_addr, 0, sizeof(my_addr)); // 修正:使用memset替代bzero
    my_addr.sin_family = AF_INET;
    my_addr.sin_port = htons(atoi(argv[2])); // 注意:如果atoi(argv[2])结果过大,可能会溢出
    my_addr.sin_addr.s_addr = inet_addr(argv[1]); // 注意:如果argv[1]不是有效的IP地址,这里会返回INADDR_NONE


	/*
	客户端不用绑定地址
    if(bind(socket_ret, (const struct sockaddr *)&my_addr, sizeof(my_addr)) < 0){
        perror("bind"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);
    }
	*/
	/*客户端不用监听
    if(listen(socket_ret, 10) < 0){
        perror("listen"); // 修正:提供完整的错误信息
        exit(EXIT_FAILURE);       
    }
	*/
	int connect_ret = connect(socket_ret, (const struct sockaddr *)&my_addr, sizeof(my_addr));
	if (connect_ret < 0)
	{
		perror("connect");
		exit(1);
	}
	
    //socklen_t len = sizeof(oth_addr);
    while(1){
		/*
		客户端不需要等待自己连接
        int client_socket = accept(socket_ret, (struct sockaddr *)&oth_addr, &len); // 修正:使用更明确的变量名

        if(client_socket < 0){
            perror("accept"); // 修正:提供完整的错误信息
            continue; // 修正:不退出程序,而是继续监听
        }
		*/

        //printf("客户端地址为: %s\n", inet_ntoa(oth_addr.sin_addr)); // 修正:添加换行符\n

        memset(buf, 0, sizeof(buf)); // 修正:使用memset替代bzero
		while (1)
		{
		fgets(buf, sizeof(buf), stdin);
		recv_data = send(socket_ret, buf, sizeof(buf) - 1, 0); // 修正:使用client_socket接收数据,并确保buf不会溢出
        //if(recv_data > 0){
        //   printf("服务器发来:%s\n", buf); // 修正:添加换行符\n
        //}

		}
		
      
        //close(client_socket); // 修正:关闭客户端套接字
    }

    // 注意:正常情况下,服务器套接字不应该在这里关闭,因为它需要持续监听新的连接
    // close(socket_ret); // 这行代码应该被注释掉或移除

    return 0;
}


http://www.kler.cn/a/397811.html

相关文章:

  • Spring中的Bean
  • 【C++】深入理解 C++ 优先级队列、容器适配器与 deque:实现与应用解析
  • 使用Python实现深度学习模型:智能食品配送优化
  • # 第20章 Cortex-M4-触摸屏
  • 【C++】list 与 string 基础与实现字符串操作
  • 飞凌嵌入式RK3576核心板已适配Android 14系统
  • Spring:bean的配置
  • XXL JOB DockerCompose部署
  • pytorch奇怪错误
  • WebRTC API分析
  • IPTV智慧云桌面,后台服务器搭建笔记
  • 《现代网络技术》读书笔记:SDN应用平面
  • 推荐一个基于协程的C++(lua)游戏服务器
  • 工业大数据分析与应用:开启智能制造新时代
  • 【mysql】基于城市多边形,配合mysql库,查询目标点是否在指定城市内
  • VSCode设置
  • RabbitMQ教程:工作队列(Work Queues)(二)
  • 推荐15个2024最新精选wordpress模板
  • centos7 升级openssl 与升级openssh 安装卸载 telnet-server
  • Go中数组和切片
  • stm32——通用定时器时钟知识点
  • 【小白可懂】微信小程序---课表渲染
  • 使用Python爬虫获取商品订单详情:从API到数据存储
  • FastAPI 中间件详解:实现高性能 Web 应用的完整指南和实际案例
  • 安装paddle
  • 鸿蒙学习基本概念