欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

c++ udp的socket通信使用jsoncpp传输

程序员文章站 2022-04-24 22:30:17
...

window平台

使用vs2013编码udp的socket,其中发送和接收数据时用json协议。


步骤

  • 下载jsoncpp:Jsoncpp是个跨平台的开源库,下载地址:http://sourceforge.net/projects/jsoncpp/
  • 解压上面下载的Jsoncpp文件,在jsoncpp-src-0.5.0/makefiles/msvc2010目录里找到jsoncpp.sln,使用你的编译器打开并编译
  • 编译后进入文件夹当前目录下的debug找到lib_json.lib;
  • 打开项目属性》配置属性》vc++目录,找到包含目录进行编辑,添加头文件与源文件的存放地址(如:\jsoncpp\jsoncpp-master\include\json)
  • 返回vc++,找到库目录,添加之前找到的lib_json.lib的目录(如:H:\jsoncpp\jsoncpp-master\makefiles\msvc2010\Debug)
  • 进入c\c++》代码生成》运行库,调整为MTD\MT模式

运行程序时遇到的问题

  • error C4996: ‘Json::Reader::Nodes’: Use CharReader and CharReaderBuilder instead
    解决:源文件开头添加:#pragma warning (disable: 4996)
  • error LNK2038: 检测到“RuntimeLibrary”的不匹配项: 值“MTd_StaticDebug”不匹配值“MDd_DynamicDebug”
    其实就是所选工程的运行库不匹配导致的

在工程上右键-》属性-》c/c++-》代码生成-》运行库
有四个选项及含义分别如下:
多线程调试Dll (/MDd) 对应的是MD_DynamicDebug
多线程Dll (/MD) 对应的是MD_DynamicRelease
多线程(/MT) 对应的是MD_StaticRelease
多线程(/MTd)对应的是MD_StaticDebug

error LNK2038: 检测到“RuntimeLibrary”的不匹配项: 值“MTd_StaticDebug”不匹配值“MDd_DynamicDebug
从上面的错误提示可知,我们原来选择的是 多线程调试Dll (/MDd) 选项 ,把它改为 多线程(/MTd)

  • warning LNK4098: 默认库“LIBCMT”与其他库的使用冲突
    链接器->输入->忽略特定库: libcmt.lib

代码懒得改,有些变量调试用后也没删除

客户端

//#define _CRT_SECURE_NO_WARNINGS  //_s版本是安全版本,像gets,gets_s,printf,printf_s之类的,但是只能在win下运行
#pragma warning(disable:4996)
#include <memory>
#include <stdio.h>  
#include <iostream>  
#include <string>  
#include <winsock2.h>  
#pragma comment(lib,"ws2_32.lib")  //编译器设置--链接库  
using namespace std;
const int PORT = 3804;
#include <json.h>

//#pragma comment(lib, "lib_json")  

int main()
{
    Json::Value root;
    root["key_string"] = Json::Value("value_string");     // 新建一个 Key(名为:key_string),赋予字符串值:"value_string"。
    root["key_number"] = Json::Value(12345);             // 新建一个 Key(名为:key_number),赋予数值:12345。
    root["key_boolean"] = Json::Value(true);             // 新建一个 Key(名为:key_boolean),赋予bool值:false。
    root["key_double"] = Json::Value(12.345);             // 新建一个 Key(名为:key_double),赋予 double 值:12.345。
    Json::FastWriter styled_writer;
    string s=styled_writer.write(root);
    //cout << root << endl;

    int n;
    WSADATA wd;
    n = WSAStartup(MAKEWORD(2, 2), &wd);
    if (n)
    {
        cout << "WSAStartup函数错误!" << endl;
        return -1;
    }
    SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);   //SOCK_DGRAM代表UDP  
    if (INVALID_SOCKET == sock)
    {
        cout << "socket建立失败!" << endl;
        return -1;
    }
    SOCKADDR_IN sa1;
    sa1.sin_family = AF_INET;//AF_INET 就是局域网,
    sa1.sin_port = htons(PORT);
    sa1.sin_addr.S_un.S_addr = inet_addr("172.05.187.1");

    //可以不用bind();系统默认随机分配
    /*sockaddr_in sa = { AF_INET };   //随机分配一个端口 (仅初始化一个值,让客户端自己分配端口)  
    n = bind(sock, (sockaddr*)&sa, sizeof(sa));//要sa1分开,不然,不能连接。
    if (n == SOCKET_ERROR)
    {
        cout << "bind函数失败!" << endl;
        cout << "错误码是:" << WSAGetLastError() << endl;
        return -1;
    }*/
    //sockaddr_in sa1 = { AF_INET, htons(8009) };   //必须使用htons,因为网络字节序的缘故  
    //sa1.sin_addr.S_un.S_addr = inet_addr("192.168.191.1");//指定要发往的IP和端口号  

    char c[256];
    strcpy(c, s.c_str());
    cout << c<< endl;
    int n1 = 1;
    while (n1)
    {

        //sendto(sock, s.c_str(), sizeof(s), 0, (sockaddr*)&sa1, sizeof(sa1)); //发送数据  

        cout << strlen(c) << endl;
        sendto(sock, c, sizeof(c), 0, (sockaddr*)&sa1, sizeof(sa1));
        fflush(stdin);//清空缓存区,移植性差,vs2015不能用
        //gets(c);//#define _CRT_SECURE_NO_WARNINGS  ,否则会报错。 不能使用gets,可用fgets(buf, BUFSIZE, stdin); 
        cin >> n1;
    }

    return 0;
}

服务器端

#pragma warning (disable: 4996) 
#include <cstdio>  
#include <iostream>  
#include <string>  
#include <winsock2.h>  
#pragma comment(lib,"ws2_32.lib")  
using namespace std;
const int PORT = 3804;
#include <json.h>
int main()
{
    int n;
    WSADATA wd;
    n = WSAStartup(MAKEWORD(2, 2), &wd);
    if (n)
    {
        cout << "WSAStartup函数错误!" << endl;
        return -1;
    }
    SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);
    if (INVALID_SOCKET == sock)
    {
        cout << "socket建立失败!" << endl;
        cout << "错误码是:" << WSAGetLastError() << endl;
        return -1;
    }
    sockaddr_in sa = { AF_INET, htons(PORT) };
    /*
    SOCKADDR_IN sa;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(PORT);
    sa.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
    */
    n = bind(sock, (sockaddr*)&sa, sizeof(sa));
    if (n == SOCKET_ERROR)
    {
        cout << "bind绑定端口失败!" << endl;
        cout << "错误码是:" << WSAGetLastError() << endl;
        return -1;
    }
    else
    {
        cout << "端口发布成功:" << PORT << endl;
    }
    char s[256];    

    while (true)
    {
        n = recv(sock, s, sizeof(s), 0); //recv返回的是实际copy的字节数  
        //s[n] = '\0';
        cout << strlen(s) << endl;
        Json::Value va;
        Json::Reader re;
        n = re.parse(s, va);
        cout << s << endl;

            cout << va << endl;
            string s = va["key_string"].asString();
            int i = va["key_number"].asInt();
            bool b = va["key_boolean"].asBool();
            double d = va["key_double"].asDouble();
            cout <<s <<i<<b <<d<< endl;



    }

    return 0;

}