当前位置：首页 » 《随便一记》 » 正文

基于win32控制台的socket网络通信程序_m0_49994790的博客

26 人参与  2022年03月26日 17:57  分类 : 《随便一记》  评论

点击全文阅读


我只是一个小白，自己第一次动手写的基于win32控制台的socket通信程序，同时程序代码也只适合与初学者，写的不好的地方也多多包涵（同时希望大佬多多指教），我也希望我分享的成果供给有需要的小白，希望能帮助到你们。

成果展示：

客户端核心代码：


void chatClient() {
    
    //请求协议版本
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (LOBYTE(wsaData.wVersion) != 2 ||
        HIBYTE(wsaData.wVersion) != 2) {
        gotoXY(4, 8);
        printf("请求协议版本失败");
    }
    else {
        gotoXY(4, 8);
        printf("请求协议版本成功");
    }

    //创建socket套接字
    clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (clientSocket == INVALID_SOCKET) {
        gotoXY(4, 9);
        printf("套接字创建失败");
        WSACleanup();
    }
    else
    {
        gotoXY(4, 9);
        printf("套接字创建成功");
    }
    //创建协议族
    SOCKADDR_IN addrConServer;
    addrConServer.sin_family = AF_INET;
    addrConServer.sin_addr.S_un.S_addr = inet_addr(IP_ADDR);
    addrConServer.sin_port = htons(LISTEN_PORT);

    //向服务器发出请求连接
    int len = sizeof(SOCKADDR);
    if (connect(clientSocket, (sockaddr*)&addrConServer, len) == SOCKET_ERROR) {
        gotoXY(4, 10);
        printf("连接失败:%d", WSAGetLastError());
        closesocket(clientSocket);
        WSACleanup();
    }
    else
    {
        gotoXY(4, 10);
        printf("连接成功");
    }
    //数据通信以及线程
    char ch[1024];
    while (1) {
        memset(ch, 0, 1024);
        gotoXY(4, 11 + var_b);
        //清楚遗留的文字
        printf("                                        ");
        gotoXY(4, 11 + var_b);
        printf(">>");
        scanf_s("%s", ch);
        send(clientSocket, ch, strlen(ch), NULL);
        var_b++;
        if (var_b == 16) {
            var_b = 0;
        }
    }
    //
}

服务器端核心代码：

void chatServer() {
    //请求协议版本
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (LOBYTE(wsaData.wVersion) != 2 ||
        HIBYTE(wsaData.wVersion) != 2) {
        gotoXY(10, 13);
        printf("请求协议失败");
    }
    else {
        gotoXY(10, 13);
        printf("请求协议版本成功");
    }
    //创建Socket套件字
    SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (serverSocket == INVALID_SOCKET)
    {
        gotoXY(10, 14);
        printf("socket套键字创建失败");
        WSACleanup();
    }
    gotoXY(10, 14);
    printf("socket套键字创建成功");

    //协议族创建
    SOCKADDR_IN addr = { 0 };
    addr.sin_family = AF_INET;
    addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); 
    addr.sin_port = htons(LISTEN_PORT);

    //绑定
    int len = sizeof(SOCKADDR);
    int r = bind(serverSocket, (SOCKADDR*)&addr, len);
    if (r == SOCKET_ERROR) {
        gotoXY(10, 15);
        printf("bind绑定失败");
        closesocket(serverSocket);
    }
    gotoXY(10, 15);
    printf("bind绑定成功");

    //监听客户端请求
    r = listen(serverSocket, 5);
    if (r == SOCKET_ERROR) {
        gotoXY(10, 16);
        printf("监听失败");
        closesocket(serverSocket);
    }
    gotoXY(10, 16);
    printf("监听成功");
    gotoXY(10, 17);
    printf("连接中......");

    //等待客户请求
    while (1) {
        
        //memset(buff, 0, 1024);
        revSocket[count] = accept(serverSocket, (SOCKADDR*)&revAddr, &lengt);
        if (revSocket[count] == INVALID_SOCKET) {
            gotoXY(10, 17);
            printf("客户端发出请求，服务器接收请求失败：");
            closesocket(serverSocket); 
            WSACleanup();
        }
        else
        {

            gotoXY(10, 17);
            printf("客户端发出请求，服务器接收请求成功");
            gotoXY(22, 7);
            printf("IP地址：%s", inet_ntoa(revAddr.sin_addr));
            gotoXY(44, 7);
            printf("对方端口：%d", ntohs(revAddr.sin_port));
            gotoXY(10, 18);
            CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)threadFunction, (char *)count, NULL, NULL);
            count++;
            //ExitThread(0);
        }
        
    }
    closesocket(serverSocket); 
    WSACleanup();
    

    /*char ch[1024];
    while (1) {
        memset(ch, 0, 1024);
        //scanf("%s",ch);
        r = recv(revSocket, ch, sizeof(ch), 0);
        if (r > 0) {
            ch[r] = 0;
            gotoXY(10, 18 + var_b);
            printf("客户端发送的数据: %s", ch);
        }
        else if (r == 0) {
            gotoXY(10, 18 + var_b);
            printf("Connection closed");
        }
        else {
            gotoXY(10, 18 + var_b);
            printf("recv failed: %d", WSAGetLastError());
        }
        var_b++;
        if (var_b == 7) {
            var_b = 0;
        }
    }*/
}

 客户端完整代码： 

#include<WinSock2.h>   
#include<graphics.h>
#include<Windows.h>
#include<stdio.h>
#include<conio.h>
#pragma comment(lib,"ws2_32.lib")
#define DESIGN "※" 
#define HEIGHT 7
#define TOTAL_HEIGHT 27
#define LISTEN_PORT 8888
#define IP_ADDR "127.0.0.1"

//全局变量 
HANDLE handle_Out;
int var_b = 0;
//函数声明 
void gotoXY(int, int);//辅助函数声明 
void createTitleBorder();//画标题框声明 
void socketTitle();//标题声明 
void chatBorder();//聊天区声明 
void rClientDorder();//客户端边框声明 
void clientTitle();//客户端标题 
void chatClient();//聊天 

/*************************************************************第二次变量声明*****************************************************************/
SOCKET clientSocket;
HWND hwnd;
int count = 0;

/*************************************************************第二次变量声明*****************************************************************/

/**********************************************************************第二次调整区************************************************************/
//创建一个线程接收客户端的消息
void recvServerMessage() {
    TCHAR recvBuff[1024];
    int recvData;
    //memset(recvBuff, 0, 1024);
    while (1) {
        memset(recvBuff, 0, 1024);
        recvData = recv(clientSocket, recvBuff, 1023, NULL);
        if (recvData > 0) {
            recvBuff[recvData] = 0;
            outtextxy(0, count * 20, recvBuff);
            count++;
            if (count == 16) {
                cleardevice();
                count = 0;
            }
        }
    }
    closesocket(clientSocket);
    WSACleanup();
    
}

/**********************************************************************第二次调整区************************************************************/

//客户端标题 
void clientTitle() {
    gotoXY(80, 10);
    printf("客");
    gotoXY(80, 12);
    printf("户");
    gotoXY(80, 14);
    printf("端");
    gotoXY(0, 27);
}
//客户端 
void rClientDorder() {
    //上边框
    for (int i = 70; i <= 90; i++) {
        gotoXY(i, 0);
        printf(DESIGN);
    }
    //上边框
    for (int i = 70; i <= 90; i++) {
        gotoXY(i, TOTAL_HEIGHT);
        printf(DESIGN);
    }
    //左边框
    for (int i = 0; i <= TOTAL_HEIGHT; i++) {
        gotoXY(70, i);
        printf(DESIGN);
    }
    //右边框 
    for (int i = 0; i <= TOTAL_HEIGHT; i++) {
        gotoXY(92, i);
        printf(DESIGN);
    }
}
//聊天框
void chatBorder() {
    //上边框 
    for (int i = 0; i <= 65; i++) {
        gotoXY(i, HEIGHT);
        printf(DESIGN);
    }
    //下边框 
    for (int i = 0; i <= 65; i++) {
        gotoXY(i, HEIGHT + 20);
        printf(DESIGN);
    }
    //左边框
    for (int i = 0; i <= 20; i++) {
        gotoXY(0, HEIGHT + i);
        printf(DESIGN);
    }
    //右边框
    for (int i = 0; i <= 20; i++) {
        gotoXY(66, HEIGHT + i);
        printf(DESIGN);
    }
    //gotoXY(0, 30);
}
//聊天 
void chatClient() {
    
    //请求协议版本
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (LOBYTE(wsaData.wVersion) != 2 ||
        HIBYTE(wsaData.wVersion) != 2) {
        gotoXY(4, 8);
        printf("请求协议版本失败");
    }
    else {
        gotoXY(4, 8);
        printf("请求协议版本成功");
    }

    //创建socket套接字
    clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (clientSocket == INVALID_SOCKET) {
        gotoXY(4, 9);
        printf("套接字创建失败");
        WSACleanup();
    }
    else
    {
        gotoXY(4, 9);
        printf("套接字创建成功");
    }
    //创建协议族
    SOCKADDR_IN addrConServer;
    addrConServer.sin_family = AF_INET;
    addrConServer.sin_addr.S_un.S_addr = inet_addr(IP_ADDR);
    addrConServer.sin_port = htons(LISTEN_PORT);

    //向服务器发出请求连接
    int len = sizeof(SOCKADDR);
    if (connect(clientSocket, (sockaddr*)&addrConServer, len) == SOCKET_ERROR) {
        gotoXY(4, 10);
        printf("连接失败:%d", WSAGetLastError());
        closesocket(clientSocket);
        WSACleanup();
    }
    else
    {
        gotoXY(4, 10);
        printf("连接成功");
    }
    //数据通信以及线程
    char ch[1024];
    while (1) {
        memset(ch, 0, 1024);
        gotoXY(4, 11 + var_b);
        //清楚遗留的文字
        printf("                                        ");
        gotoXY(4, 11 + var_b);
        printf(">>");
        scanf_s("%s", ch);
        send(clientSocket, ch, strlen(ch), NULL);
        var_b++;
        if (var_b == 16) {
            var_b = 0;
        }
    }
    //
}

//标题
void socketTitle() {
    gotoXY(43, 2);
    printf("Socket网络通信");
    gotoXY(0, 30);
}
//画标题边框 
void createTitleBorder() {
    //画上边框 
    for (int i = 35; i < 65; i++) {
        gotoXY(i, 0);
        printf(DESIGN);
    }
    //画下边框 
    for (int i = 35; i < 65; i++) {
        gotoXY(i, 5);
        printf(DESIGN);
    }
    //画左边框
    for (int i = 0; i <= 5; i++) {
        gotoXY(35, i);
        printf(DESIGN);
    }
    //画右边框
    for (int i = 0; i <= 5; i++) {
        gotoXY(65, i);
        printf(DESIGN);
    }
}
//辅助函数 
void gotoXY(int x, int y) {
    COORD pos = { x,y };
    handle_Out = GetStdHandle(STD_OUTPUT_HANDLE);
    SetConsoleCursorPosition(handle_Out, pos);
}

int main() {
    TCHAR szTitle[] = "Client客户端";
    TCHAR sTitle[] = "客户端输出框";
    system("mode con cols=95 lines=28");
    //system("color 2f");
    SetWindowLong(FindWindow("ConsoleWindowClass", NULL), GWL_STYLE, GetWindowLong(FindWindow("ConsoleWindowClass", NULL), GWL_STYLE) & ~WS_SIZEBOX & ~WS_MAXIMIZEBOX & ~WS_MINIMIZEBOX);
    hwnd = initgraph(256, 300, SHOWCONSOLE);
    SetWindowText(hwnd, sTitle);
    SetConsoleTitle(szTitle);
    //创建标题 边框 
    createTitleBorder();
    //标题
    socketTitle();
    //客户端
    rClientDorder();
    //客户端标题 
    clientTitle();
    //聊天框
    chatBorder();
    /**********************************************************************第二次调整区************************************************************/
    //创建线程
    CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)recvServerMessage, NULL, NULL, NULL);
    /**********************************************************************第二次调整区************************************************************/
    //聊天 
    chatClient();
    // 关闭句柄 
    ExitThread(0);
    CloseHandle(handle_Out);
    return 0;
}

服务器端完整代码：

#include<WinSock2.h>
#include<Windows.h>
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<conio.h>
#pragma comment(lib,"ws2_32.lib")
#define TOTAL_HEIGHT 27
#define DESIGN "※" 
#define LISTEN_PORT 8888
#define IP_ADDR "192.168.1.100"

/***************************************************************函数声明区域**********************************************************************************************/
void listenBorder();//接听框声明 
void ipBoder();// ip框声明
void portBorder();//端口框声明 
void showBorderInfo();//信息显示
void gotoXY(int, int);//辅助函数声明
void titleShow();//文字 
void serverBorder();//客户端边框 
void chatServer();//通信函数 
void threadFunction(int id);//多线程
/***************************************************************函数声明区域**********************************************************************************************/
//

/***************************************************************全局变量区域**********************************************************************************************/
//全局变量 
HANDLE handle_Out;
int var_b = 0;

SOCKET revSocket[1024];
int count = 0;

SOCKADDR_IN  revAddr = { 0 };
int lengt = sizeof(SOCKADDR);
/***************************************************************全局变量区域**********************************************************************************************/
//


/***************************************************************WIN32控制台程序修饰窗口和数据输出区域**********************************************************************************************/
//客户端边框 
void serverBorder() {
    //上边框
    for (int i = 70; i <= 90; i++) {
        gotoXY(i, 0);
        printf(DESIGN);
    }
    //上边框
    for (int i = 70; i <= 90; i++) {
        gotoXY(i, TOTAL_HEIGHT);
        printf(DESIGN);
    }
    //左边框
    for (int i = 0; i <= TOTAL_HEIGHT; i++) {
        gotoXY(70, i);
        printf(DESIGN);
    }
    //右边框 
    for (int i = 0; i <= TOTAL_HEIGHT; i++) {
        gotoXY(92, i);
        printf(DESIGN);
    }
    gotoXY(80, 10);
    printf("服");
    gotoXY(80, 12);
    printf("务");
    gotoXY(80, 14);
    printf("器");
    gotoXY(80, 16);
    printf("端");
    gotoXY(0, 28);
}
//接听框
void listenBorder() {

    //下边框 
    for (int i = 8; i <= 16; i++) {
        gotoXY(i, 8);
        printf(DESIGN);
    }
    titleShow();
    gotoXY(0, 28);
}
void titleShow() {
    gotoXY(9, 7);
    printf("开始监听");
}
// ip框声明
void ipBoder() {
    //下边框 
    for (int i = 20; i <= 40; i++) {
        gotoXY(i, 8);
        printf(DESIGN);
    }
    gotoXY(0, 28);
}
//端口框声明
void portBorder() {
    for (int i = 44; i <= 57; i++) {
        gotoXY(i, 8);
        printf(DESIGN);
    }
    gotoXY(0, 28);
}
//信息显示
void showBorderInfo() {
    for (int i = 0; i <= 58; i++) {
        gotoXY(i, 10);
        printf(DESIGN);
    }
    //上边框 
    for (int i = 8; i <= 58; i++) {
        gotoXY(i, 12);
        printf(DESIGN);
    }
    //下边框 
    for (int i = 8; i <= 58; i++) {
        gotoXY(i, 29);
        printf(DESIGN);
    }
    //左边框 
    for (int i = 0; i <= 17; i++) {
        gotoXY(8, 12 + i);
        printf(DESIGN);
    }
    //右边框 
    for (int i = 0; i <= 17; i++) {
        gotoXY(58, 12 + i);
        printf(DESIGN);
    }
    //gotoXY(0, 28);
}
//辅助函数 
void gotoXY(int x, int y) {
    COORD pos = { x,y };
    handle_Out = GetStdHandle(STD_OUTPUT_HANDLE);
    SetConsoleCursorPosition(handle_Out, pos);
}
/***************************************************************WIN32控制台程序修饰窗口和数据输出区域**********************************************************************************************/
//


/***************************************************************Socket网络通信区域**********************************************************************************************/
//通信函数 
void chatServer() {
    //请求协议版本
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (LOBYTE(wsaData.wVersion) != 2 ||
        HIBYTE(wsaData.wVersion) != 2) {
        gotoXY(10, 13);
        printf("请求协议失败");
    }
    else {
        gotoXY(10, 13);
        printf("请求协议版本成功");
    }
    //创建Socket套件字
    SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (serverSocket == INVALID_SOCKET)
    {
        gotoXY(10, 14);
        printf("socket套键字创建失败");
        WSACleanup();
    }
    gotoXY(10, 14);
    printf("socket套键字创建成功");

    //协议族创建
    SOCKADDR_IN addr = { 0 };
    addr.sin_family = AF_INET;
    addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); 
    addr.sin_port = htons(LISTEN_PORT);

    //绑定
    int len = sizeof(SOCKADDR);
    int r = bind(serverSocket, (SOCKADDR*)&addr, len);
    if (r == SOCKET_ERROR) {
        gotoXY(10, 15);
        printf("bind绑定失败");
        closesocket(serverSocket);
    }
    gotoXY(10, 15);
    printf("bind绑定成功");

    //监听客户端请求
    r = listen(serverSocket, 5);
    if (r == SOCKET_ERROR) {
        gotoXY(10, 16);
        printf("监听失败");
        closesocket(serverSocket);
    }
    gotoXY(10, 16);
    printf("监听成功");
    gotoXY(10, 17);
    printf("连接中......");

    //等待客户请求
    while (1) {
        
        //memset(buff, 0, 1024);
        revSocket[count] = accept(serverSocket, (SOCKADDR*)&revAddr, &lengt);
        if (revSocket[count] == INVALID_SOCKET) {
            gotoXY(10, 17);
            printf("客户端发出请求，服务器接收请求失败：");
            closesocket(serverSocket); 
            WSACleanup();
        }
        else
        {

            gotoXY(10, 17);
            printf("客户端发出请求，服务器接收请求成功");
            gotoXY(22, 7);
            printf("IP地址：%s", inet_ntoa(revAddr.sin_addr));
            gotoXY(44, 7);
            printf("对方端口：%d", ntohs(revAddr.sin_port));
            gotoXY(10, 18);
            CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)threadFunction, (char *)count, NULL, NULL);
            count++;
            //ExitThread(0);
        }
        
    }
    closesocket(serverSocket); 
    WSACleanup();
    

    /*char ch[1024];
    while (1) {
        memset(ch, 0, 1024);
        //scanf("%s",ch);
        r = recv(revSocket, ch, sizeof(ch), 0);
        if (r > 0) {
            ch[r] = 0;
            gotoXY(10, 18 + var_b);
            printf("客户端发送的数据: %s", ch);
        }
        else if (r == 0) {
            gotoXY(10, 18 + var_b);
            printf("Connection closed");
        }
        else {
            gotoXY(10, 18 + var_b);
            printf("recv failed: %d", WSAGetLastError());
        }
        var_b++;
        if (var_b == 7) {
            var_b = 0;
        }
    }*/
}

/***************************************************************Socket网络通信区域**********************************************************************************************/
//

/***************************************************************多线程调用**********************************************************************************************/
void threadFunction(int id) {
    TCHAR buff[1024];
    char buff1[1024];
    int re;
    while (1){
        memset(buff, 0, 1024);
        re = recv(revSocket[id], buff, 1023, NULL);
        if (re > 0) {
            buff[re] = 0;
            //清楚遗留的文字
            gotoXY(10, 18 + var_b);
            printf("                                        ");
            gotoXY(10, 18 + var_b);
            printf("<%d>号客户端发送的数据: %s",id+1, buff);
            for (int i = 0; i < count; i++) {
                send(revSocket[i], buff, 1023, NULL);
            }
            
        }
        else if (re == 0) {
            gotoXY(10, 18 + var_b);
            printf("Connection closed");
            closesocket(revSocket[id]);
            WSACleanup();
        }
        else {
            gotoXY(10, 18 + var_b);
            printf("recv failed: %d", WSAGetLastError());
            closesocket(revSocket[id]);
            WSACleanup();
            continue;
        }
        //memset(buff, 0, 1024);
        var_b++;
        if (var_b == 11) {
            var_b = 0;
        }
        
    };
}

/***************************************************************多线程调用**********************************************************************************************/
/

int main(){
    TCHAR szTitle[] = "Server服务器";
    system("mode con cols=96 lines=30");
    //system("color 2f");
    SetWindowLong(FindWindow("ConsoleWindowClass", NULL), GWL_STYLE, GetWindowLong(FindWindow("ConsoleWindowClass", NULL), GWL_STYLE) & ~WS_SIZEBOX & ~WS_MAXIMIZEBOX & ~WS_MINIMIZEBOX);
    SetConsoleTitle(szTitle);
    //接听 
    listenBorder();
    //ip框 
    ipBoder();
    //端口 
    portBorder();
    //客户端 
    serverBorder();
    //信息显示
    showBorderInfo();
    //通信函数
    chatServer();
    //关闭句柄
    CloseHandle(handle_Out);
    return 0;
}


点击全文阅读


本文链接：http://m.zhangshiyu.com/post/36796.html

边框  请求  客户端  
<< 上一篇 下一篇 >>

  • 评论（0）
  • 赞助本站

◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。

最新文章

  • 普通医生：他竟成了一国神医小说，普通医生：他竟成了一国神医京磊京墨墨姜宇秦秀兰
  • 求叶欢欢吴氏叶德荣小说免费资源
  • 完整版《专职奶爸：我娶了女儿的班主任》免费阅读
  • 以权定盘全章节免费在线阅读，杨志远杨石完结版
  • 已完结小说《租车追女神后，他成了真豪门》在线全文阅读
  • 一胎双宝：阴鸷总裁今天又上门求婚（谢逸林）在线免费阅读
  • 主人公叫芊芊肖强秦天的小说哪里免费看
  • 我反派啊！女主演我干嘛？免费阅读，我反派啊！女主演我干嘛？周巧巧许默
  • 男女主人公叶宁杨琳小说被女神截胡后，我是高手这件事全城皆知全文免费阅读
  • 男女主人公叫林宇陈芸的小说免费资源
  • 小说《被丢入乱葬岗：她滔天归来！》全文阅读
  • 《商家真刑啊！这样产品也敢送来直播？》小说大结局免费试读 刻沐沐哥小说

    关于我们 | 我要投稿 | 免责申明

    Copyright © 2020-2022 ZhangShiYu.com Rights Reserved.豫ICP备2022013469号-1