C++实现json形式的Socket传输图片

2020-03-20 20:02:12于丽

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

二.客户端

1.main.cpp

#include<WINSOCK2.H>
#include<STDIO.H>
#include<iostream>
#include<cstring>
#include <string>
#include <fstream>
#include "Bash64.h"
#include "json1.hpp"
 
using namespace std;
using json = nlohmann::json;
#pragma comment(lib, "ws2_32.lib")
 
char chBuf1[3888888], chBuf2[3888888];
 
int main()
{
 
 FILE *fIn1, *fIn2;
 int nRead1, nRead2;
 
 WORD sockVersion = MAKEWORD(2, 2);
 WSADATA data;
 if (WSAStartup(sockVersion, &data) != 0)
 {
 return 0;
 }
 
 std::string num = std::to_string(1);
 std::string chFileIn1 = "E:"+num+".jpg";
 num = std::to_string(2);
 std::string chFileIn2 = "E:" + num + ".jpg";
 
 SOCKET sclient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 if (sclient == INVALID_SOCKET)
 {
 printf("invalid socket!");
 return 0;
 }
 
 sockaddr_in serAddr;
 serAddr.sin_family = AF_INET;
 serAddr.sin_port = htons(8888);
 serAddr.sin_addr.S_un.S_addr = inet_addr("192.168.3.72");
 if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR)
 { //连接失败 
 printf("connect error !");
 closesocket(sclient);
 return 0;
 }
 
 char chFileIn3[100], chFileIn4[100];
 strcpy(chFileIn3, chFileIn1.c_str());
 strcpy(chFileIn4, chFileIn2.c_str());
 fIn1 = fopen(chFileIn3, "rb");
 fIn2 = fopen(chFileIn4, "rb");
 if (fIn1 == NULL || fIn2 == NULL)
 {
 printf("打开读取文件失败");
 return 0;
 }
 //读文件
 json data1;
 
 //fread()读取成功返回值为实际读回的数据个数(单位为Byte)
 nRead1 = fread(chBuf1, sizeof(char), 3888888, fIn1);
 nRead2 = fread(chBuf2, sizeof(char), 3888888, fIn2);
 //base64编码 封装进json
 string imgBase64_1 = base64_encode(chBuf1, nRead1);
 string imgBase64_2 = base64_encode(chBuf2, nRead2);
 data1["imgA"] = imgBase64_1;
 data1["imgB"] = imgBase64_2;
 fclose(fIn1);
 fclose(fIn2);
 
 //显式转换为string 
 std::string s = data1.dump();
 const char * sendData;
 sendData = s.c_str(); //string转const char* 
 //char * sendData = "你好,TCP服务端,我是客户端n";
 send(sclient, sendData, strlen(sendData), 0);
 
 //send()用来将数据由指定的socket传给对方主机
 //int send(int s, const void * msg, int len, unsigned int flags)
 //s为已建立好连接的socket,msg指向数据内容,len则为数据长度,参数flags一般设0
 //成功则返回实际传送出去的字符数,失败返回-1,错误原因存于error 
 
 char recData[266680];
 int ret = recv(sclient, recData, 266680, 0);
 if (ret>0) {
 recData[ret] = 0x00;
 //printf(recData);
 }
 closesocket(sclient);
 
 WSACleanup();
 system("pause");
 return 0;
 
}

2.Bash64.h

#ifndef __BASE64_H__
#define __BASE64_H__
 
#include <iostream>
#include <string>
 
static const std::string base64_chars =
"ABCDEFGHIJKLMNOPQRSTUVWXYZ"
"abcdefghijklmnopqrstuvwxyz"
"0123456789+/";
 
static inline bool is_base64(const char c)
{
 return (isalnum(c) || (c == '+') || (c == '/'));
}
 
std::string base64_encode(const char * bytes_to_encode, unsigned int in_len)
{
 std::string ret;
 int i = 0;
 int j = 0;
 unsigned char char_array_3[3];
 unsigned char char_array_4[4];
 
 while (in_len--)
 {
 char_array_3[i++] = *(bytes_to_encode++);
 if (i == 3)
 {
 char_array_4[0] = (char_array_3[0] & 0xfc) >> 2;
 char_array_4[1] = ((char_array_3[0] & 0x03) << 4) + ((char_array_3[1] & 0xf0) >> 4);
 char_array_4[2] = ((char_array_3[1] & 0x0f) << 2) + ((char_array_3[2] & 0xc0) >> 6);
 char_array_4[3] = char_array_3[2] & 0x3f;
 for (i = 0; (i <4); i++)
 {
 ret += base64_chars[char_array_4[i]];
 }
 i = 0;
 }
 }
 if (i)
 {
 for (j = i; j < 3; j++)
 {
 char_array_3[j] = '';
 }
 
 char_array_4[0] = (char_array_3[0] & 0xfc) >> 2;
 char_array_4[1] = ((char_array_3[0] & 0x03) << 4) + ((char_array_3[1] & 0xf0) >> 4);
 char_array_4[2] = ((char_array_3[1] & 0x0f) << 2) + ((char_array_3[2] & 0xc0) >> 6);
 char_array_4[3] = char_array_3[2] & 0x3f;
 
 for (j = 0; (j < i + 1); j++)
 {
 ret += base64_chars[char_array_4[j]];
 }
 
 while ((i++ < 3))
 {
 ret += '=';
 }
 
 }
 return ret;
}
 
std::string base64_decode(std::string const & encoded_string)
{
 int in_len = (int)encoded_string.size();
 int i = 0;
 int j = 0;
 int in_ = 0;
 unsigned char char_array_4[4], char_array_3[3];
 std::string ret;
 
 while (in_len-- && (encoded_string[in_] != '=') && is_base64(encoded_string[in_])) {
 char_array_4[i++] = encoded_string[in_]; in_++;
 if (i == 4) {
 for (i = 0; i <4; i++)
 char_array_4[i] = base64_chars.find(char_array_4[i]);
 
 char_array_3[0] = (char_array_4[0] << 2) + ((char_array_4[1] & 0x30) >> 4);
 char_array_3[1] = ((char_array_4[1] & 0xf) << 4) + ((char_array_4[2] & 0x3c) >> 2);
 char_array_3[2] = ((char_array_4[2] & 0x3) << 6) + char_array_4[3];
 
 for (i = 0; (i < 3); i++)
 ret += char_array_3[i];
 i = 0;
 }
 }
 if (i) {
 for (j = i; j <4; j++)
 char_array_4[j] = 0;
 
 for (j = 0; j <4; j++)
 char_array_4[j] = base64_chars.find(char_array_4[j]);
 
 char_array_3[0] = (char_array_4[0] << 2) + ((char_array_4[1] & 0x30) >> 4);
 char_array_3[1] = ((char_array_4[1] & 0xf) << 4) + ((char_array_4[2] & 0x3c) >> 2);
 char_array_3[2] = ((char_array_4[2] & 0x3) << 6) + char_array_4[3];
 
 for (j = 0; (j < i - 1); j++) ret += char_array_3[j];
 }
 
 return ret;
}
#endif