c http post file
原文链接： c http post file
基于C语言实现HTTP POST 表单形式上传文件 - fangye945a的博客 - CSDN博客
all:
gcc -pthread -I. http_post.c
clean:
rm -f a.out
POST /Server/interface_picture_upload.action?appid=wmj_BZ2WeU7K1iP&appsecret=MXkMcT43JsIgAwBwVJ30EbA2ovIcpfCQ&sn=0 HTTP/1.1
Host: test.inteink.com
User-Agent: Mozilla/5.0 (X11; Ubuntu; Linux i686; rv:59.0) Gecko/20100101 Firefox/59.0
Accept: text/html,application/xhtml+xml,application/xml;q=0.9,/;q=0.8
Accept-Language: en-US,en;q=0.5
Accept-Encoding: gzip, deflate
Content-Type: multipart/form-data; boundary=---------------------------1573810344383
Content-Length: 1163
Connection: close
Upgrade-Insecure-Requests: 1
DNT: 1
-----------------------------1573810344383
Content-Disposition: form-data; name="file"; filename="a.jpg"
Content-Type: image/jpeg
1231231231231231231231231231231231231fghoiijjjjjjjjjjjj
#ifndef __HTTP_POST__
#define __HTTP_POST__
#define SERVER_ADDR "localhost"
#define SERVER_PORT 8080
#define HTTP_HOST "test.inteink.com"
#define HTTP_PATH "/Server/interface_picture_upload.action?appid=wmj_BZ2WeU7K1iP&appsecret=MXkMcT43JsIgAwBwVJ30EbA2ovIcpfCQ&sn=%s"
#define HTTP_HEAD "POST %s HTTP/1.1\r\n"\
"Host: %s\r\n"\
"User-Agent: Mozilla/5.0 (X11; Ubuntu; Linux i686; rv:59.0) Gecko/20100101 Firefox/59.0\r\n"\
"Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\n"\
"Accept-Language: en-US,en;q=0.5\r\n"\
"Accept-Encoding: gzip, deflate\r\n"\
"Content-Type: multipart/form-data; boundary=%s\r\n"\
"Content-Length: %ld\r\n"\
"Connection: close\r\n"\
"Upgrade-Insecure-Requests: 1\r\n"\
"DNT: 1\r\n\r\n"\
#define UPLOAD_REQUEST "--%s\r\n"\
"Content-Disposition: form-data; name=\"file\"; filename=\"%s\"\r\n"\
"Content-Type: image/jpeg\r\n\r\n"
unsigned long get_file_size(const char *path);
int http_post_upload_pic(const unsigned char *IP, const unsigned int port,char *URL, const char *filepath,
char *ack_json, int ack_len); //Post方式上传图片
void *Upload_Pic_Task(void *argv);
int Upload_Pic_Task_Init();
#endif
#include <stdlib.h>
#include <sys/types.h>
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <string.h>
#include <sys/stat.h>
//#include "App_sdk_control.h"
#include "http_post.h"
//#include "sqlite3_database.h"
unsigned char header[1024]={0};
unsigned char send_request[1024]={0};
unsigned char send_end[1024]={0};
unsigned char http_boundary[64]={0};
unsigned char http_param[256]={0};
//extern volatile int upload_pic_flag; //图片上传标志
volatile int upload_pic_flag; //图片上传标志
//extern CONFIG_INFO device_info; //设备配置信息
unsigned long get_file_size(const char *path)
{
unsigned long filesize = -1;
struct stat statbuff;
if(stat(path, &statbuff) < 0){
return filesize;
}else{
filesize = statbuff.st_size;
}
return filesize;
}
int http_post_upload_pic(const unsigned char *IP, const unsigned int port,char *URL, const char *filepath,
char *ack_json, int ack_len) //Post方式上传图片
{
int cfd = -1;
int recbytes = -1;
int sin_size = -1;
char buffer[1024*10]={0};
struct sockaddr_in s_add,c_add;
cfd = socket(AF_INET, SOCK_STREAM, 0); //创建socket套接字
if(-1 == cfd)
{
printf("socket fail ! \r\n");
return -1;
}
bzero(&s_add,sizeof(struct sockaddr_in));
s_add.sin_family=AF_INET; //IPV4
s_add.sin_addr.s_addr= inet_addr(IP);
s_add.sin_port=htons(port);
//printf("s_addr = %#x ,port : %#x\r\n",s_add.sin_addr.s_addr,s_add.sin_port);
if(-1 == connect(cfd,(struct sockaddr *)(&s_add), sizeof(struct sockaddr))) //建立TCP连接
{
printf("connect fail !\r\n");
return -1;
}
//获取毫秒级的时间戳用于boundary的值
long long int timestamp;
struct timeval tv;
gettimeofday(&tv,NULL);
timestamp = (long long int)tv.tv_sec * 1000 + tv.tv_usec;
snprintf(http_boundary,64,"---------------------------%lld",timestamp);
unsigned long totalsize = 0;
unsigned long filesize = get_file_size(filepath); //文件大小
unsigned long request_len = snprintf(send_request,1024,UPLOAD_REQUEST,http_boundary,filepath); //请求信息
unsigned long end_len = snprintf(send_end,1024,"\r\n--%s--\r\n",http_boundary); //结束信息
totalsize = filesize + request_len + end_len;
//snprintf(http_param,256,HTTP_PATH,device_info.devId);//HTTP参数设置
snprintf(http_param,256,HTTP_PATH);//HTTP参数设置
printf("http_param = %s\n",http_param);
unsigned long head_len = snprintf(header,1024,HTTP_HEAD,http_param,URL,http_boundary,totalsize); //头信息
totalsize += head_len;
char* request = (char*)malloc(totalsize); //申请内存用于存放要发送的数据
if (request == NULL){
printf("malloc request fail !\r\n");
return -1;
}
request[0] = '\0';
/******* 拼接http字节流信息 *********/
strcat(request,header); //http头信息
strcat(request,send_request); //文件图片请求信息
FILE* fp = fopen(filepath, "rb+"); //打开要上传的图片
if (fp == NULL){
printf("open file fail!\r\n");
return -1;
}
int readbyte = fread(request+head_len+request_len, 1, filesize, fp);//读取上传的图片信息
if(readbyte < 1) //小于1024个字节 则认为图片有问题
{
printf("Read picture data fail!\r\n");
return -1;
}
memcpy(request+head_len+request_len+filesize,send_end,end_len); //http结束信息
/********* 发送http 请求 ***********/
if(-1 == write(cfd,request,totalsize))
{
printf("send http package fail!\r\n");
return -1;
}
/********* 接受http post 回复信息 ***********/
if(-1 == (recbytes = read(cfd,buffer,10240)))
{
printf("read http ACK fail !\r\n");
return -1;
}
buffer[recbytes]='\0';
int index = 0,start_flag = 0;
int ack_json_len = 0;
for(index = 0; index<recbytes; index++)
{
if(buffer[index] == '{')
{
start_flag = 1;
}
if(start_flag)
ack_json[ack_json_len++] = buffer[index]; //遇到左大括号则开始拷贝
if(buffer[index] == '}') //遇到右大括号则停止拷贝
{
ack_json[ack_json_len] = '\0';
break;
}
}
if(ack_json_len > 0 && ack_json[ack_json_len-1] == '}') //遇到花括号且有json字符串
{
printf("Receive:%s\n",ack_json);
}
else
{
ack_json[0] = '\0';
printf("Receive http ACK fail!!\n");
printf("--- ack_json_len = %d\n",ack_json_len);
}
free(request);
fclose(fp);
close(cfd);
return 0;
}
void *Upload_Pic_Task(void *argv)
{
int ack_len = 256;
char ack_json[256]={0};
while(1)
{
if(upload_pic_flag)
{
printf("%s",PIC_SAVE_PATH);
int ret = http_post_upload_pic(SERVER_ADDR,SERVER_PORT,HTTP_HOST,PIC_SAVE_PATH,ack_json,ack_len); //Post方式上传图片
if(ret == -1)
{
printf("\n\n----------- Post picture Fail!!\n");
}
upload_pic_flag = 0;
}
usleep(1000*20);
}
}
int Upload_Pic_Task_Init()
{
pthread_t p_thread;
int ret = 0;
ret = pthread_create(&p_thread, NULL, Upload_Pic_Task, NULL);
if(ret != 0)
{
printf("Error: Create Upload_Pic_Task thread failed!\n");
return -1;
}else
printf("Create Upload_Pic_Task thread success!\n");
return 0;
}
int main(int argc, char *argv[]){
Upload_Pic_Task_Init();
while(1){
upload_pic_flag=1;
sleep(5);
}
}
/*
int main(int argc, char *argv[])
{
int ack_len = 256;
char ack_json[256]={0};
int ret = http_post_upload_pic(SERVER_ADDR, SERVER_PORT,SERVER_URL,argv[1],ack_json,ack_len); //Post方式上传图片
if(ret == -1)
{
printf("\n\n----------- Post picture Fail!!\n");
}
return 0;
}
*/