基于windows环境利用VS下通过Linux环境下服务器进行UDP通信交流

news/2024/5/18 13:17:13 标签: udp, linux, 网络, windows

目录

前言

Linux

udpServer.cc-toc" style="margin-left:80px;">udpServer.cc

udpServer.hpp-toc" style="margin-left:80px;">udpServer.hpp

makefile

windows-toc" style="margin-left:0px;">windows

细节1 --  头文件引入

细节2 -- 固定写法

细节3 -- 结束后清理

细节4 -- socket返回值接受

细节5 -- 套接字创建(一样的写法)

细节6 -- 填写sockaddr_in结构体

细节7 -- 接发收数据

细节8 -- 报错信息的处理

解决方法

细节9 -- 中文编码不支持

结果

源码

Windows

udpclient.cc-toc" style="margin-left:40px;">udpclient.cc

本文参考文献

前言

简单的UDP网络程序  -- 简单UDP搭建教程

经过大刀阔斧之后现在我们有了一个只能接受消息的简单UDP server

 

Linux

udpServer.cc">udpServer.cc

#include "udpServer.hpp"
#include <memory>
#include <fstream>
#include <unordered_map>
#include <signal.h>

using namespace std;
using namespace Server;

static void Usage(string proc)
{
    cout << "Usage:\n\t" << proc << " local_port\n\n"; // 命令提示符
}

// demo1
void handlerMessage(int sockfd, string clientip, uint16_t clientport, string message)
{
    string response_message = message;
    response_message += " [server echo]";

    // 开始返回
    struct sockaddr_in client;
    bzero(&client, sizeof(client));

    client.sin_family = AF_INET;
    client.sin_port = htons(clientport);
    client.sin_addr.s_addr = inet_addr(clientip.c_str()); // 字符串转网络(点分十进制 转 数字序列)

    sendto(sockfd, response_message.c_str(), response_message.size(), 0, (const sockaddr *)&client, sizeof(client));
}

// ./udpServer port
int main(int argc, char *argv[])
{
    if (argc != 2) // 这里我们只想要传递两个参数，所以当argc不是3的时候就直接报错退出就行了，注意文件名运行的那个指令也会算进去所以argc +1
    {
        Usage(argv[0]);
        exit(USAGE_ERR);
    }
    uint16_t port = atoi(argv[1]); // 使用atoi强转，因为argv里面放置的都是字符串，类型需要转换

    std::unique_ptr<udpServer> usvr(new udpServer(handlerMessage, port));

    usvr->initServer();
    usvr->start();

    return 0;
}

udpServer.hpp">udpServer.hpp

#pragma once
 
#include <iostream>
#include <string>
#include <strings.h>
#include <cerrno>
#include <functional>
#include <cstring>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
 
namespace Server
{
    using namespace std;
    static const string defaultIp = "0.0.0.0"; // 直接使用这个缺省值,代表监听机器上的所有ip端口
    static const int gnum = 1024;
    enum
    {
        USAGE_ERR = 1,
        SOCKET_ERR,
        BIND_ERR,
        OPEN_ERR
    }; // 1.命令行输入错误 2.创建套接字错误 3.绑定端口号错误
 
    typedef function<void(int, string, uint16_t, string)> func_t;
 
    class udpServer
    {
    public:
        udpServer(const func_t &cd, const uint16_t &port, const string &ip = defaultIp)
            : _callback(cd), _port(port), _ip(ip), _sockfd(-1)
        {
        }
        void initServer() // 初始化
        {
            // 1.创建套接字
            _sockfd = socket(AF_INET, SOCK_DGRAM, 0);
            if (_sockfd == -1)
            {
                cerr << "socket error: " << errno << " : " << strerror(errno) << endl;
                exit(SOCKET_ERR); // 创建套接字失败直接终止进程
            }
            cout << "udpServer success: "
                 << " : " << _sockfd << endl;
 
            // 2.绑定套接字(port, ip)
            // 未来服务器要明确的port， 不能随意改变 -- 变了别人就找不到了
            struct sockaddr_in local;     // 这里是定义了一个变量，在栈上，而且是用户层，还没有bind之前都是没有产生联系
            bzero(&local, sizeof(local)); // 先填 0 再修正
            // 注意这下面几个名字是拼接出来的，就是那个##拼接而来的
            local.sin_family = AF_INET;                     // 这里设置与套接字的AF_INET设置意义是不一样的，socket是创建一个网络通信的套接字，在这里是填充一个sockaddr_in的结构体用来网络通信
            local.sin_port = htons(_port);                  // 你如果给别人发信息，你的port和ip要不要发送给对方？ 答案是要的
            local.sin_addr.s_addr = inet_addr(_ip.c_str()); // 1. string->unit32_t  2. htonl(); -> inet_addr
            // local.sin_addr.s_addr = htonl(INADDR_ANY);  //可以主机转网络，不够也可以不处理，直接赋值也行
            int n = bind(_sockfd, (struct sockaddr *)&local, sizeof(local));
            if (n == -1)
            {
                cerr << "bin error: " << errno << " : " << strerror(errno) << endl;
                exit(BIND_ERR);
            }
            // UDP Server 的预备工作完成
        }
        void start() // 启动
        {
            // 服务器的本质其实就是一个死循环
            char buffer[gnum]; // 定义一个数组来充当缓冲区
            for (;;)
            {
                // 读取数据
                struct sockaddr_in peer;
                socklen_t len = sizeof(peer); // 必须设置成这个结构体的大小，当作为输入时，告诉recvfrom的长度的多少
                ssize_t s = recvfrom(_sockfd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)&peer, &len);
                // 关系两件事情
                // 1.数据是什么？ 2. 谁发的？
                if (s > 0)
                {
                    buffer[s] = 0;
                    // 因为是从网络上读取的，所以一定要转，可以使用接口
                    // inet_ntoa 将一个网络字节序的IP地址（也就是结构体in_addr类型变量）转化为点分十进制的IP地址（字符串）
                    string clientip = inet_ntoa(peer.sin_addr); // 1.网络序列 2.整数 -> 点分十进制的ip
                    uint16_t clientport = ntohs(peer.sin_port);
                    string message = buffer;
 
                    cout << clientip << "[" << clientport << "]# " << message << endl;
 
                    //我们只把数据读上来就完了吗？ 我们要对数据进行处理 -- 所以我们用回调函数的方式来解决
                    _callback(_sockfd, clientip, clientport, message);
                }
            }
        }
        ~udpServer() // 析构
        {
        }
 
    private:
        uint16_t _port;
        // 实际上，一款网络服务器，不建议指明一个IP，因为一个服务器可以能有多个ip，万一用户使用其他的ip地址来访问该端口号(这里是8080,就收不到了)，这也是我们为什么使用0.0.0.0的IP缺省值
        string _ip;
        int _sockfd;
        func_t _callback; // 回调函数，用以处理数据
    };
}

 

makefile

cc=g++
udpServer:udpServer.cc
	$(cc) -o $@ $^ -std=c++11
 
.PHONY:clean
clean:
	rm -f udpServer

windows">windows

方法和Linux下没有什么本质的差别，并且差别很小，只有一点细节需要注意

关于需要的库之类的在安装VS的时候就自动携带了

细节1 -- <WinSock2.h> 头文件引入

 

在Windows下使用socket协议进行编程需要进入一个库<WinSock2.h>

并且使用库时需要指明版本

这里使用的是

#pragma comment(lib, "ws2_32.lib") 

w -- Windows

s  -- socket

2  -- 版本号

32 -- 32位 

 

细节2 -- 固定写法

 

固定写法

这Windows下使用需要初始化信息，创建一个结构体，这里WSAStartup的用处对比版本，MAKEWORD是构建一个2.2版本的放到wsd里面去，因为在Windows下UDP客户端有版本，即使用的库和版本号是要匹配的，不过这段代码后面是对我们多大用处的，基本上是固定写法

	WSAData wsd;           //初始化信息
    //启动Winsock
    if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0) {
        /*进行WinSocket的初始化,windows 初始化socket网络库，申请2，2的版本，windows socket编程必须先初始化。*/
        cout << "WSAStartup Error = " << WSAGetLastError() << endl;
        return 0;
    }
    else {
        cout << "WSAStartup Success" << endl;
    }

细节3 -- 结束后清理

用完之后需要清理，加上这一句就行了

    //清理
    WSACleanup();

细节4 -- socket返回值接受

我们需要创建一个SOCKET 类型的对象接受socket返回值

 

细节5 -- 套接字创建(一样的写法)

一样的写法

 

 

细节6 -- 填写sockaddr_in结构体

        Windows下对sockaddr_in进行了封装，用大写的，不过我们这里为了和Linux下保持一致就直接沿用Linux的那一套

 

    struct sockaddr_in server;
    server.sin_family = AF_INET;
    server.sin_port = htons(serverport);
    server.sin_addr.s_addr = inet_addr(serverip.c_str());

 

 

细节7 -- 接发收数据

第四个参数为0 -- 阻塞式接发送

#define NUM 1024
    char inbuffer[NUM];
    string line;
	while (true)
	{
        //发送逻辑
        cout << "Please Enter";
        getline(cin, line);                     //0 代表阻塞式发送
        int n = sendto(csock, line.c_str(), line.size(), 0, (struct sockaddr*)&server, sizeof(server));
        if (n < 0)
        {
            cerr << "sendto error!" << endl;
            break;
        }


        //收取数据
        struct sockaddr_in peer;
        int peerlen = sizeof(peer);
        inbuffer[0] = 0;    //C风格清空
        n = recvfrom(csock, inbuffer, sizeof(inbuffer) - 1, 0, (struct sockaddr*)&server, &peerlen);
        if (n > 0)
        {
            inbuffer[n] = 0;
            cout << "server 返回的消息是# " << inbuffer << endl;
        }
        else break;
	}

细节8 -- 报错信息的处理

到此处其实代码基本完成，不过VS总有一些小毛病，

 

解决方法

把警告禁掉就行了，安全不安全，它说的不算，4996号报警声明一下就行了

#pragma warning(disable:4996)

细节9 -- 中文编码不支持

        因为是跨操作系统的，所以会涉及到编码的问题，这是普遍存在的，我们这里主要不是处理该问题，就不做处理了

结果

 

源码

Windows

udpclient.cc">udpclient.cc

#pragma warning(disable:4996)
#include <iostream>
#include <string>
#include <cstring>
#include <WinSock2.h>

using namespace std;

//因为客户并不知道输入port和地址，所以这里直接写到代码里面去了，未来启动就可以自动链接了
//这里图方便并没有写入配置文件中去
uint16_t serverport = 8080;
string serverip = "20.214.205.14"; 

#pragma comment(lib, "ws2_32.lib")
int main()
{
	WSAData wsd;           //初始化信息
    //启动Winsock
    if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0) {
        /*进行WinSocket的初始化,windows 初始化socket网络库，申请2，2的版本，windows socket编程必须先初始化。*/
        cout << "WSAStartup Error = " << WSAGetLastError() << endl;
        return 0;
    }
    else {
        cout << "WSAStartup Success" << endl;
    }

    //创建socket套接字
    SOCKET csock = socket(AF_INET, SOCK_DGRAM, 0);//IPPROTO_UDP
    //SOCKET_ERROR -- 其实就是-1
    if (csock == SOCKET_ERROR) {
        cout << "socket Error = " << WSAGetLastError() << endl;
        return 1;
    }
    else {
        cout << "socket Success" << endl;
    }

    //填写套接字
    struct sockaddr_in server;
    server.sin_family = AF_INET;
    server.sin_port = htons(serverport);
    server.sin_addr.s_addr = inet_addr(serverip.c_str());

#define NUM 1024
    char inbuffer[NUM];
    string line;
	while (true)
	{
        //发送逻辑
        cout << "Please Enter# ";
        getline(cin, line);                     //0 代表阻塞式发送
        int n = sendto(csock, line.c_str(), line.size(), 0, (struct sockaddr*)&server, sizeof(server));
        if (n < 0)
        {
            cerr << "sendto error!" << endl;
            break;
        }


        //收取数据
        struct sockaddr_in peer;
        int peerlen = sizeof(peer);
        inbuffer[0] = 0;    //C风格清空
        n = recvfrom(csock, inbuffer, sizeof(inbuffer) - 1, 0, (struct sockaddr*)&server, &peerlen);
        if (n > 0)
        {
            inbuffer[n] = 0;
            cout << "server 返回的消息是# " << inbuffer << endl;
        }
        else break;
	}

    closesocket(csock); //关不关无所谓
    //清理 -- 这里要清理
    WSACleanup();

	return 0;
}

本文参考文献

【干货】Windows平台基于udp的socket网络编程开发_windows udp socket_Antrn的博客-CSDN博客


http://www.niftyadmin.cn/n/401055.html

相关文章

chatgpt赋能python：Python如何优化SEO

chatgpt赋能python：Python如何优化SEO

Python如何优化SEO SEO是指搜索引擎优化&#xff0c;是提高网站在搜索引擎中排名的技术实践。Python是一种高效、易用、灵活的编程语言&#xff0c;可以被应用于SEO的优化过程中。 关键词优化 关键词是SEO过程中的重要元素&#xff0c;Python可以帮助我们快速优化关键词。以…
阅读更多...
01：快速入门爬虫

01：快速入门爬虫

1.引导 1.Robots协议 Robots协议&#xff08;爬虫协议&#xff09;的全称是“网络爬虫排除标准”&#xff08;Robots Exclusion Protocol&#xff09;&#xff0c;网站通过Robots协议告诉搜索引擎哪些页面可以抓取&#xff0c;哪些页面不能抓取。该协议是国际互联网界通行的道…
阅读更多...
【vulnhub靶场】MATRIX-BREAKOUT: 2 MORPHEUS

【vulnhub靶场】MATRIX-BREAKOUT: 2 MORPHEUS

文章目录 描述&#xff1a;一、开启靶机信息收集二层发现三层探测信息整理&#xff1a;初步攻击basic爆破&#xff1a;已知漏洞利用文件上传 后渗透测试后渗透测试 描述&#xff1a; 这是《黑客帝国》系列的第二部&#xff0c;副标题是《沉睡魔咒:1》。它的主题是回到第一部《…
阅读更多...
ActiveReportsJS 4.0.2 Crack ActiveReportsJS New

ActiveReportsJS 4.0.2 Crack ActiveReportsJS New

ActiveReportsJS - 高级 JavaScript 报告解决方案 ActiveReportsJS 是一个强大的 Web 应用程序报告工具&#xff0c;它允许开发人员和报告作者轻松地在他们的应用程序中设计和显示报告。凭借广泛的功能&#xff0c;例如向下钻取、运行时数据过滤和参数驱动的报告&#xff0c;以…
阅读更多...
ADAS方案的简单比较

ADAS方案的简单比较

ADAS方案的简单比较 1 概述2 厂商Tesla硬件布局网络基础结构&#xff1a;HydraNet多头网络 NVIDIA百度&#xff08;Apollo&#xff09;版本历史硬件布局软件框架各版本框架 WaymoVolvo-Uber 3 芯片4 其他from [最全自动驾驶技术架构和综述](https://blog.csdn.net/buptgshengod…
阅读更多...
chatgpt赋能python：Python如何更改？

chatgpt赋能python：Python如何更改？

Python如何更改&#xff1f; 如果您想成为一名成功的Python程序员&#xff0c;那么您需要知道如何更改Python代码。在这篇文章中&#xff0c;我们将介绍Python如何更改&#xff0c;并提供一些实用的技巧和建议来使您的编码更加高效和有用。 什么是Python&#xff1f; Python…
阅读更多...
【JUC基础】15. Future模式

【JUC基础】15. Future模式

目录 1、前言 2、什么是Future 2.1、传统程序调用 3、JDK中的Future 3.1、Future相关API 3.2、FutureTask 3.2.1、FutureTask实现 3.2.2、FutureTask相关API 3.3、CompletableFuture 3.3.1、thenApply 3.3.2、异步任务编排之thenCompose() 3.3.3、异步任务编排之th…
阅读更多...
FusionCharts Suite XT 3.20.X Crack

FusionCharts Suite XT 3.20.X Crack

3.20版# 2023年3月24日 新功能 FusionCharts 3.20版本引入了一种新方法_changeXAxisCordinates&#xff0c;它允许用户自动更改x轴&#xff0c;使其在图例或数据交互时居中对齐。 FusionCharts 3.20版本更新了Angular集成&#xff0c;支持Angular版本14和15。 FusionChart…
阅读更多...
最新文章

Copyright @ 2022~2023