当前位置:首页 > 通信资讯 > 正文

c++发送json格式数据(c语言发送json数据)

本文实例为大家分享了C++实现json形式的Socket传输图片的具体代码,供大家参考,具体内容如下

大致流程:客户端读取图片,经过Base64编码,转成字符串的形式,保存到json中,通过socket传到服务端,然后Base64解码,再转换成图片

一.服务端

c++发送json格式数据(c语言发送json数据)

1.main.cpp

  1. #include <iostream>
  2. #include <stdio.h>
  3. #include "Base64_1.h"
  4. #include <winsock2.h>
  5. #include "json1.hpp"
  6. #pragma comment(lib,"ws2_32.lib")
  7. using json = nlohmann::json;
  8. char revData[3888888];
  9. bool WritePhotoFile(std::basic_string<TCHAR> strFileName, std::string &strData)
  10. {
  11. HANDLE hFile;
  12. hFile = CreateFile(strFileName.c_str(), GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
  13. if (hFile == INVALID_HANDLE_VALUE)
  14. {
  15. return false;
  16. }
  17. CBase64 base64;
  18. int datalen(0);
  19. DWORD dwritelen(0);
  20. std::string strdcode = base64.Decode(strData.data(), strData.size(), datalen);
  21. if (!WriteFile(hFile, strdcode.data(), datalen, &dwritelen, NULL))
  22. {
  23. CloseHandle(hFile);
  24. return false;
  25. }
  26. CloseHandle(hFile);
  27. return true;
  28. }
  29. int main(int argc, char* argv[])
  30. {
  31. //初始化WSA
  32. WORD sockVersion = MAKEWORD(2, 2);
  33. WSADATA wsaData;
  34. if (WSAStartup(sockVersion, &wsaData) != 0)
  35. {
  36. return 0;
  37. }
  38. //创建套接字
  39. SOCKET slisten = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  40. if (slisten == INVALID_SOCKET)
  41. {
  42. printf("socket error !");
  43. return 0;
  44. }
  45. //绑定IP和端口
  46. sockaddr_in sin;
  47. sin.sin_family = AF_INET;
  48. sin.sin_port = htons(8888);
  49. sin.sin_addr.S_un.S_addr = INADDR_ANY;
  50. if (bind(slisten, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR)
  51. {
  52. printf("bind error !");
  53. }
  54. //开始监听
  55. if (listen(slisten, 5) == SOCKET_ERROR)
  56. {
  57. printf("listen error !");
  58. return 0;
  59. }
  60. //循环接收数据
  61. SOCKET sClient;
  62. sockaddr_in remoteAddr;
  63. int nAddrlen = sizeof(remoteAddr);
  64. //revData = (char*)malloc(sizeof(char) * 1000000);
  65. int i = 1;
  66. while (true)
  67. {
  68. printf("等待连接...\n");
  69. sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen);
  70. if (sClient == INVALID_SOCKET)
  71. {
  72. printf("accept error !");
  73. continue;
  74. }
  75. printf("接受到一个连接:%s \r\n", inet_ntoa(remoteAddr.sin_addr));
  76. //接收数据
  77. int ret = recv(sClient, revData, 3888888, 0);
  78. if (ret > 0)
  79. {
  80. revData[ret] = 0x00;
  81. json o = json::parse(revData);
  82. for (json::iterator it = o.begin(); it != o.end(); ++it) {
  83. //std::cout << it.key() << " : " << it.value() << "\n";
  84. if (it.key() == "imgA"|| it.key() == "imgB")
  85. {
  86. std::string num = std::to_string(i++);
  87. std::string strFileName = "D:\\"+ num +".jpg";
  88. std::string val = it.value();
  89. WritePhotoFile(strFileName, val);
  90. }
  91. }
  92. //std::cout<< json::parse(revData)<< std::endl;
  93. //printf(revData);
  94. }
  95. //发送数据
  96. //const char * sendData = "你好,TCP客户端!\n";
  97. //send(sClient, sendData, strlen(sendData), 0);
  98. closesocket(sClient);
  99. }
  100. closesocket(slisten);
  101. WSACleanup();
  102. return 0;
  103. }

2.Base64.cpp

  1. #include"Base64_1.h"
  2. CBase64::CBase64()
  3. {
  4. }
  5. CBase64::~CBase64()
  6. {
  7. }
  8. std::string CBase64::Encode(const char* Data, int DataByte)
  9. {
  10. //编码表
  11. const char EncodeTable[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
  12. //返回值
  13. std::string strEncode;
  14. unsigned char Tmp[4] = { 0 };
  15. int LineLength = 0;
  16. for (int i = 0; i<(int)(DataByte / 3); i++)
  17. {
  18. Tmp[1] = *Data++;
  19. Tmp[2] = *Data++;
  20. Tmp[3] = *Data++;
  21. strEncode += EncodeTable[Tmp[1] >> 2];
  22. strEncode += EncodeTable[((Tmp[1] << 4) | (Tmp[2] >> 4)) & 0x3F];
  23. strEncode += EncodeTable[((Tmp[2] << 2) | (Tmp[3] >> 6)) & 0x3F];
  24. strEncode += EncodeTable[Tmp[3] & 0x3F];
  25. if (LineLength += 4, LineLength == 76) { strEncode += "\r\n"; LineLength = 0; }
  26. }
  27. //对剩余数据进行编码
  28. int Mod = DataByte % 3;
  29. if (Mod == 1)
  30. {
  31. Tmp[1] = *Data++;
  32. strEncode += EncodeTable[(Tmp[1] & 0xFC) >> 2];
  33. strEncode += EncodeTable[((Tmp[1] & 0x03) << 4)];
  34. strEncode += "==";
  35. }
  36. else if (Mod == 2)
  37. {
  38. Tmp[1] = *Data++;
  39. Tmp[2] = *Data++;
  40. strEncode += EncodeTable[(Tmp[1] & 0xFC) >> 2];
  41. strEncode += EncodeTable[((Tmp[1] & 0x03) << 4) | ((Tmp[2] & 0xF0) >> 4)];
  42. strEncode += EncodeTable[((Tmp[2] & 0x0F) << 2)];
  43. strEncode += "=";
  44. }
  45. return strEncode;
  46. }
  47. std::string CBase64::Decode(const char* Data, int DataByte, int& OutByte)
  48. {
  49. //解码表
  50. const char DecodeTable[] =
  51. {
  52. 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
  53. 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
  54. 62, // '+'
  55. 0, 0, 0,
  56. 63, // '/'
  57. 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, // '0'-'9'
  58. 0, 0, 0, 0, 0, 0, 0,
  59. 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
  60. 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, // 'A'-'Z'
  61. 0, 0, 0, 0, 0, 0,
  62. 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38,
  63. 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, // 'a'-'z'
  64. };
  65. //返回值
  66. std::string strDecode;
  67. int nValue;
  68. int i = 0;
  69. while (i < DataByte)
  70. {
  71. if (*Data != '\r' && *Data != '\n')
  72. {
  73. nValue = DecodeTable[*Data++] << 18;
  74. nValue += DecodeTable[*Data++] << 12;
  75. strDecode += (nValue & 0x00FF0000) >> 16;
  76. OutByte++;
  77. if (*Data != '=')
  78. {
  79. nValue += DecodeTable[*Data++] << 6;
  80. strDecode += (nValue & 0x0000FF00) >> 8;
  81. OutByte++;
  82. if (*Data != '=')
  83. {
  84. nValue += DecodeTable[*Data++];
  85. strDecode += nValue & 0x000000FF;
  86. OutByte++;
  87. }
  88. }
  89. i += 4;
  90. }
  91. else// 回车换行,跳过
  92. {
  93. Data++;
  94. i++;
  95. }
  96. }
  97. return strDecode;
  98. }

3.Base64_1.h

  1. //++Base64.h
  2. #pragma once
  3. #include <string>
  4. class CBase64
  5. {
  6. public:
  7. public:
  8. CBase64();
  9. ~CBase64();
  10. /*编码
  11. DataByte
  12. [in]输入的数据长度,以字节为单位
  13. */
  14. std::string Encode(const char* Data, int DataByte);
  15. /*解码
  16. DataByte
  17. [in]输入的数据长度,以字节为单位
  18. OutByte
  19. [out]输出的数据长度,以字节为单位,请不要通过返回值计算
  20. 输出数据的长度
  21. */
  22. std::string Decode(const char* Data, int DataByte, int& OutByte);
  23. };

4.json.hpp 去网上下载吧,个人感觉比jsoncpp好用一些(我里面的json1.hpp就是json.hpp)

二.客户端

c++发送json格式数据(c语言发送json数据)

1.main.cpp

  1. #include<WINSOCK2.H>
  2. #include<STDIO.H>
  3. #include<iostream>
  4. #include<cstring>
  5. #include <string>
  6. #include <fstream>
  7. #include "Bash64.h"
  8. #include "json1.hpp"
  9. using namespace std;
  10. using json = nlohmann::json;
  11. #pragma comment(lib, "ws2_32.lib")
  12. char chBuf1[3888888], chBuf2[3888888];
  13. int main()
  14. {
  15. FILE *fIn1, *fIn2;
  16. int nRead1, nRead2;
  17. WORD sockVersion = MAKEWORD(2, 2);
  18. WSADATA data;
  19. if (WSAStartup(sockVersion, &data) != 0)
  20. {
  21. return 0;
  22. }
  23. std::string num = std::to_string(1);
  24. std::string chFileIn1 = "E:\\"+num+".jpg";
  25. num = std::to_string(2);
  26. std::string chFileIn2 = "E:\\" + num + ".jpg";
  27. SOCKET sclient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  28. if (sclient == INVALID_SOCKET)
  29. {
  30. printf("invalid socket!");
  31. return 0;
  32. }
  33. sockaddr_in serAddr;
  34. serAddr.sin_family = AF_INET;
  35. serAddr.sin_port = htons(8888);
  36. serAddr.sin_addr.S_un.S_addr = inet_addr("192.168.3.72");
  37. if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR)
  38. { //连接失败
  39. printf("connect error !");
  40. closesocket(sclient);
  41. return 0;
  42. }
  43. char chFileIn3[100], chFileIn4[100];
  44. strcpy(chFileIn3, chFileIn1.c_str());
  45. strcpy(chFileIn4, chFileIn2.c_str());
  46. fIn1 = fopen(chFileIn3, "rb");
  47. fIn2 = fopen(chFileIn4, "rb");
  48. if (fIn1 == NULL || fIn2 == NULL)
  49. {
  50. printf("打开读取文件失败");
  51. return 0;
  52. }
  53. //读文件
  54. json data1;
  55. //fread()读取成功返回值为实际读回的数据个数(单位为Byte)
  56. nRead1 = fread(chBuf1, sizeof(char), 3888888, fIn1);
  57. nRead2 = fread(chBuf2, sizeof(char), 3888888, fIn2);
  58. //base64编码 封装进json
  59. string imgBase64_1 = base64_encode(chBuf1, nRead1);
  60. string imgBase64_2 = base64_encode(chBuf2, nRead2);
  61. data1["imgA"] = imgBase64_1;
  62. data1["imgB"] = imgBase64_2;
  63. fclose(fIn1);
  64. fclose(fIn2);
  65. //显式转换为string
  66. std::string s = data1.dump();
  67. const char * sendData;
  68. sendData = s.c_str(); //string转const char*
  69. //char * sendData = "你好,TCP服务端,我是客户端\n";
  70. send(sclient, sendData, strlen(sendData), 0);
  71. //send()用来将数据由指定的socket传给对方主机
  72. //int send(int s, const void * msg, int len, unsigned int flags)
  73. //s为已建立好连接的socket,msg指向数据内容,len则为数据长度,参数flags一般设0
  74. //成功则返回实际传送出去的字符数,失败返回-1,错误原因存于error
  75. char recData[266680];
  76. int ret = recv(sclient, recData, 266680, 0);
  77. if (ret>0) {
  78. recData[ret] = 0x00;
  79. //printf(recData);
  80. }
  81. closesocket(sclient);
  82. WSACleanup();
  83. system("pause");
  84. return 0;
  85. }

2.Bash64.h

  1. #ifndef __BASE64_H__
  2. #define __BASE64_H__
  3. #include <iostream>
  4. #include <string>
  5. static const std::string base64_chars =
  6. "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
  7. "abcdefghijklmnopqrstuvwxyz"
  8. "0123456789+/";
  9. static inline bool is_base64(const char c)
  10. {
  11. return (isalnum(c) || (c == '+') || (c == '/'));
  12. }
  13. std::string base64_encode(const char * bytes_to_encode, unsigned int in_len)
  14. {
  15. std::string ret;
  16. int i = 0;
  17. int j = 0;
  18. unsigned char char_array_3[3];
  19. unsigned char char_array_4[4];
  20. while (in_len--)
  21. {
  22. char_array_3[i++] = *(bytes_to_encode++);
  23. if (i == 3)
  24. {
  25. char_array_4[0] = (char_array_3[0] & 0xfc) >> 2;
  26. char_array_4[1] = ((char_array_3[0] & 0x03) << 4) + ((char_array_3[1] & 0xf0) >> 4);
  27. char_array_4[2] = ((char_array_3[1] & 0x0f) << 2) + ((char_array_3[2] & 0xc0) >> 6);
  28. char_array_4[3] = char_array_3[2] & 0x3f;
  29. for (i = 0; (i <4); i++)
  30. {
  31. ret += base64_chars[char_array_4[i]];
  32. }
  33. i = 0;
  34. }
  35. }
  36. if (i)
  37. {
  38. for (j = i; j < 3; j++)
  39. {
  40. char_array_3[j] = '\0';
  41. }
  42. char_array_4[0] = (char_array_3[0] & 0xfc) >> 2;
  43. char_array_4[1] = ((char_array_3[0] & 0x03) << 4) + ((char_array_3[1] & 0xf0) >> 4);
  44. char_array_4[2] = ((char_array_3[1] & 0x0f) << 2) + ((char_array_3[2] & 0xc0) >> 6);
  45. char_array_4[3] = char_array_3[2] & 0x3f;
  46. for (j = 0; (j < i + 1); j++)
  47. {
  48. ret += base64_chars[char_array_4[j]];
  49. }
  50. while ((i++ < 3))
  51. {
  52. ret += '=';
  53. }
  54. }
  55. return ret;
  56. }
  57. std::string base64_decode(std::string const & encoded_string)
  58. {
  59. int in_len = (int)encoded_string.size();
  60. int i = 0;
  61. int j = 0;
  62. int in_ = 0;
  63. unsigned char char_array_4[4], char_array_3[3];
  64. std::string ret;
  65. while (in_len-- && (encoded_string[in_] != '=') && is_base64(encoded_string[in_])) {
  66. char_array_4[i++] = encoded_string[in_]; in_++;
  67. if (i == 4) {
  68. for (i = 0; i <4; i++)
  69. char_array_4[i] = base64_chars.find(char_array_4[i]);
  70. char_array_3[0] = (char_array_4[0] << 2) + ((char_array_4[1] & 0x30) >> 4);
  71. char_array_3[1] = ((char_array_4[1] & 0xf) << 4) + ((char_array_4[2] & 0x3c) >> 2);
  72. char_array_3[2] = ((char_array_4[2] & 0x3) << 6) + char_array_4[3];
  73. for (i = 0; (i < 3); i++)
  74. ret += char_array_3[i];
  75. i = 0;
  76. }
  77. }
  78. if (i) {
  79. for (j = i; j <4; j++)
  80. char_array_4[j] = 0;
  81. for (j = 0; j <4; j++)
  82. char_array_4[j] = base64_chars.find(char_array_4[j]);
  83. char_array_3[0] = (char_array_4[0] << 2) + ((char_array_4[1] & 0x30) >> 4);
  84. char_array_3[1] = ((char_array_4[1] & 0xf) << 4) + ((char_array_4[2] & 0x3c) >> 2);
  85. char_array_3[2] = ((char_array_4[2] & 0x3) << 6) + char_array_4[3];
  86. for (j = 0; (j < i - 1); j++) ret += char_array_3[j];
  87. }
  88. return ret;
  89. }
  90. #endif

3.json.hpp 上面有链接(我里面的json1.hpp就是json.hpp)

Hit:服务端和客户端的Base64文件不一样,是因为当时服务端接收json时,Base64解码成图片出现了问题,又去找大神的博客,把服务端的Base64文件换了。然后能进行正常的传输图片,客户端就懒得换了~

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

原文链接:https://blog.csdn.net/weixin_42755375/article/details/81590967

如果您对该产品感兴趣,请填写办理(客服微信:xiaoxiongyidong)

为您推荐:

发表评论

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