cjson libcurl 发送请求给python 接受数据和处理数据 参考了一下别人的方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <curl/curl.h>
#include <cJSON/cJSON.h>
//#define POSTURL
"http://www.xiami.com/member/login"
#define POSTURL
"http://192.168.169.1:10099/reg"
#define POSTFIELDS "username=dsb12&password=1"
#define FILENAME
"curlposttest.log"
//解决办法 动态数组 控制buf的大小
typedef struct UserData
{
char* buf;
int len;// alloc
这里没作处理 应该随时根据长度 rellaoc重新分配才对
int used; // used length realloc:
}UserData;
struct curl_slist* headers = NULL;
UserData d;
void parse(char* jsonbuf)
{
cJSON* root = cJSON_Parse(jsonbuf);
cJSON* result = cJSON_GetObjectItem(root, "result");
printf("%s=%sn", result->string, result->valuestring);
cJSON* shuju
= cJSON_GetObjectItem(root, "datas");
cJSON* code = cJSON_GetObjectItem(shuju, "code");
printf("%s=%gn", code->string, code->valuedouble);
cJSON* myarr = cJSON_GetObjectItem(shuju,"data");
if(myarr)
{
int size = cJSON_GetArraySize(myarr);
printf("%dn",size);
int ii;
for(ii=0;ii<size;ii++)
{
cJSON* childNode = cJSON_GetArrayItem(myarr, ii);
if(childNode)
{
cJSON* child = cJSON_GetObjectItem(childNode,"name");
if(child)
{
//printf("Get child name : %sn", child->valuestring);
printf("%s=%gn", child->string, child->valuedouble);
}
cJSON* child1 = cJSON_GetObjectItem(childNode,"info");
if(child1)
{
//printf("Get child name : %sn", child->valuestring);
printf("%s=%sn", child1->string, child1->valuestring);
}
}
}
}
}
size_t write_data(void* buffer,size_t size,size_t nmemb,void *stream)
{
memcpy(d.buf+d.len, buffer, size*nmemb);
//strcpy(d.buf+d.len, buffer, size*nmemb);
d.len += size*nmemb;
FILE *fptr = (FILE*)stream;
fwrite(buffer,size,nmemb,fptr);
return size*nmemb;
}
int main(int argc,char *argv[])
{
CURL *curl;
CURLcode res;
FILE* fptr;
struct curl_slist *http_header = NULL;
if ((fptr = fopen(FILENAME,"w")) == NULL)
{
fprintf(stderr,"fopen file error:%sn",FILENAME);
return -1;
}
char username[1024];
fgets(username, sizeof(username), stdin);
username[strlen(username)-1]=0;
char password[1024];
fgets(password, sizeof(password), stdin);
password[strlen(password)-1] = 0;
/*
{
username: username,
password: password
}
{}
*/
cJSON* json = cJSON_CreateObject();
cJSON_AddItemToObject(json, "username", cJSON_CreateString(username));
cJSON_AddItemToObject(json, "password", cJSON_CreateString(password));
char* json_buf = cJSON_Print(json);
printf("%sn", json_buf);
d.buf=(char*)malloc(8192);
curl = curl_easy_init();
if (!curl)
{
fprintf(stderr,"curl init failedn");
return -1;
}
curl_easy_setopt(curl,CURLOPT_URL,POSTURL); //url地址
//	curl_easy_setopt(curl,CURLOPT_POSTFIELDS,POSTFIELDS); //post参数
curl_easy_setopt(curl,CURLOPT_POSTFIELDS,json_buf); //post参数 不需要统>计长度 因为json 是字符串
curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,write_data); //对返回的数据进行操作的函数地址
curl_easy_setopt(curl,CURLOPT_WRITEDATA,fptr); //这是write_data的第四个参数值
curl_easy_setopt(curl,CURLOPT_POST,1); //设置问非0表示本次操作为post
curl_easy_setopt(curl,CURLOPT_VERBOSE,1); //打印调试信息
headers=curl_slist_append(headers, "Content-Type:application/json;charset=UTF-8");
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
//	curl_easy_setopt(curl,CURLOPT_HEADER,1); //将响应头信息和相应体一起传给write_data
//	curl_easy_setopt(curl,CURLOPT_FOLLOWLOCATION,1); //设置为非0,响应头信息location
//curl_easy_setopt(curl,CURLOPT_COOKIEFILE,"/Users/zhu/CProjects/curlposttest.cookie");
res = curl_easy_perform(curl);
printf("============");
printf("%dn",res);
printf("============");
if (res != CURLE_OK)
{
switch(res)
{
case CURLE_UNSUPPORTED_PROTOCOL:
fprintf(stderr,"不支持的协议,由URL的头部指定n");
case CURLE_COULDNT_CONNECT:
fprintf(stderr,"不能连接到remote主机或者代理n");
case CURLE_HTTP_RETURNED_ERROR:
fprintf(stderr,"http返回错误n");
case CURLE_READ_ERROR:
fprintf(stderr,"读本地文件错误n");
default:
fprintf(stderr,"返回值:%dn",res);
}
return -1;
}
curl_slist_free_all(headers); /* free the list again */
curl_easy_cleanup(curl);
printf("%sn",d.buf);
printf("json返回的数据长度%lun",strlen(d.buf));
printf("===============");
parse(d.buf);
printf("===============");
printf("接收到的长度%dn",d.len);
}

1
2
3
4
5
6
7
8
9
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
int main()
{
char *buf="{"result": "no", "shuju": [{"name": 1, "info": "dsb12", "price": "c4ca4238a0b923820dcc509a6f75849b", "sdate": "None", "edate": "None", "id": null}, {"name": 2, "info": "d", "price": "8fa14cdd754f91cc6554c9e71929cce7", "sdate": "None", "edate": "None", "id": null}, {"name": 3, "info": "fk", "price": "b25ffa68ad761f8578cc61700c0140ed", "sdate": "None", "edate": "None", "id": null}, {"name": 4, "info": "hurry", "price": "46c48bec0d282018b9d167eef7711b2c", "sdate": "None", "edate": "None", "id": null}], "datas": {"code": 1, "data": [{"name": 1, "info": "dsb12", "price": "c4ca4238a0b923820dcc509a6f75849b", "sdate": "None", "edate": "None", "id": null}, {"name": 2, "info": "d", "price": "8fa14cdd754f91cc6554c9e71929cce7", "sdate": "None", "edate": "None", "id": null}, {"name": 3, "info": "fk", "price": "b25ffa68ad761f8578cc61700c0140ed", "sdate": "None", "edate": "None", "id": null}, {"name": 4, "info": "hurry", "price": "46c48bec0d282018b9d167eef7711b2c", "sdate": "None", "edate": "None", "id": null}]}}";
printf("%lun",strlen(buf));
return 0;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
from flask import Flask
from flask import request
import json
import mysql
import uuid
import hashlib
app = Flask("live-server")
def toJson(**kwargs):
return json.dumps(kwargs) # 把json转换成字符串
# 创建session
def getSession():
uuidObj = uuid.uuid1()
uuidStr = str(uuidObj)
# 对UUID进行 md5 hash
print(type(uuidStr))
# str, bytes
QString QByteArray
return hashlib.md5(uuidStr.encode()).hexdigest()
@app.route("/addcourse", methods=['POST', 'GET'])
def addcourse():
try:
json = request.json
print(json)
session = json['session']
name = json['name']
desc = json['desc']
teacher = json['teacher']
sdate = json['sdate']
edate = json['edate']
price = json['price']
conn = mysql.get_conn()
cursor = conn.cursor()
mysql.select(cursor, "select id from tuser where session='%s'" % session)
if cursor.rowcount == 0:
return toJson(result="err", reason="session error")
sql = "insert into tcourse (name, info, price, sdate, edate) values ('%s', '%s', %d, '%s', '%s')" % (
name, desc, price, sdate, edate
)
print(sql)
mysql.insert(cursor, sql)
mysql.select(cursor, "select max(id) from tcourse")
courseid = cursor.fetchone()[0]
mysql.select(cursor, "select id from tuser where name='%s'" % teacher)
userid = cursor.fetchone()[0]
mysql.insert(cursor, "insert into trelation (userid, courseid, relation) values(%d, %d, 0)" % (userid, courseid))
conn.commit()
except Exception as e:
print(str(e))
return toJson(result = "err", reason=str(e))
return toJson(result='ok')
@app.route("/charge", methods=['POST', 'GET'])
def charge():
try:
json = request.json
print(json)
session = json['session']
money = json['money']
conn = mysql.get_conn()
cursor = conn.cursor()
# 1. 用户表
#
1. 先获得原来的余额
#
2. 相加再更新
# 2. 充值记录表
#
1. 插入一条记录
mysql.select(cursor, "select balance, id from tuser where session='%s'" % session)
if cursor.rowcount == 0:
return toJson(result="err", reason="session error")
record = cursor.fetchone()
balance = record[0]
userid = record[1]
new_balance = balance + money
mysql.update(cursor, "update tuser set balance=%d where id=%d" % (new_balance, userid))
mysql.insert(cursor, "insert into tcharge (userid, money, balance) values (%d, %d, %d)" % (userid,money, new_balance))
conn.commit()
return toJson(result="ok", balance=new_balance)
except Exception as e:
return toJson(result="err", reason=str(e))
@app.route("/login", methods=['POST', 'GET'])
def login():
try:
json = request.json
print(json)
username = json['username']
password = json['password']
password = hashlib.md5(password.encode()).hexdigest()
type = json['type']
conn = mysql.get_conn()
cursor = conn.cursor()
mysql.select(cursor, "select * from tuser where name='%s' and pass='%s'" % (username, password))
if cursor.rowcount == 1:
session = getSession()
mysql.update(cursor, "update tuser set session='%s' where name='%s'" % (session, username))
conn.commit()
return toJson(result = "ok", session = session)
except Exception as e:
return toJson(result = "err", reason = str(e))
# 3. 返回数据给客户端
# return
return toJson(result = "err", reason = "username or password error")
@app.route("/reg", methods=['POST', 'GET'])
def reg():
print(1)
#print(request.form['username'])
#print(request.args.post('password'))
try:
# 1. 获取客户端的数据
json1 = request.json
print(json1)
# a = request.get_data()
# dict1 = json.loads(a)
# print(dict1)
if json1 :
username = json1['username']
password = json1['password']
else:
username = request.form['username']
password = request.form['password']
password = hashlib.md5(password.encode()).hexdigest()
# 2. 写入数据库
# 使用pymysql访问数据
conn = mysql.get_conn()
cursor = conn.cursor()
mysql.insert(cursor, "insert into tuser (name, pass)values('%s', '%s')" % (username, password))
conn.commit()
# {
#
result: ok
# }
# {
#
result: err,
#
reason: whasdfsadf
# }
except Exception as e:
return toJson(result = "err", reason = str(e))
# 3. 返回数据给客户端
# return
cursor.execute("select * from tuser limit 4")
print(cursor.rowcount)
courses = []
data = {}
for i in range(cursor.rowcount):
record = cursor.fetchone()
course = {}
course["name"] = record[0]
course["info"] = record[1]
course["price"] = record[2]
course["sdate"] = str(record[3])
course["edate"] = str(record[4])
course["id"] = record[5]
courses.append(course)
data['code'] = 1
data['data'] = courses
print(data)
print(toJson(result='no',shuju=courses,datas=data))
return(toJson(result='no',shuju=courses,datas=data))
app.run(host="0.0.0.0", port=10099)
#{'code': 1, 'data': [{'name': 1, 'info': 'cc', 'price': 'cc', 'sdate': '0', 'edate': 'None', 'id': None}, {'name': 3, 'info': 'ccc', 'price': 'ccc', 'sdate': '0', 'edate': 'None', 'id': None}, {'name': 4, 'info': 'a', 'price': '0cc175b9c0f1b6a831c399e269772661', 'sdate': 'None', 'edate': 'None', 'id': None}, {'name': 12, 'info': 'e', 'price': 'e1671797c52e15f763380b45e841ec32', 'sdate': 'None', 'edate': 'None', 'id': None}]}
# {"result": "no", "shuju": [{"name": 1, "info": "cc", "price": "cc", "sdate": "0", "edate": "None", "id": null}, {"name": 3, "info": "ccc", "price": "ccc", "sdate": "0", "edate": "None", "id": null}, {"name": 4, "info": "a", "price": "0cc175b9c0f1b6a831c399e269772661", "sdate": "None", "edate": "None", "id": null}, {"name": 12, "info": "e", "price": "e1671797c52e15f763380b45e841ec32", "sdate": "None", "edate": "None", "id": null}], "datas": {"code": 1, "data": [{"name": 1, "info": "cc", "price": "cc", "sdate": "0", "edate": "None", "id": null}, {"name": 3, "info": "ccc", "price": "ccc", "sdate": "0", "edate": "None", "id": null}, {"name": 4, "info": "a", "price": "0cc175b9c0f1b6a831c399e269772661", "sdate": "None", "edate": "None", "id": null}, {"name": 12, "info": "e", "price": "e1671797c52e15f763380b45e841ec32", "sdate": "None", "edate": "None", "id": null}]}}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
{
"result": "no",
"shuju": [
{
"name": 1,
"info": "dsb12",
"price": "c4ca4238a0b923820dcc509a6f75849b",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 2,
"info": "d",
"price": "8fa14cdd754f91cc6554c9e71929cce7",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 3,
"info": "fk",
"price": "b25ffa68ad761f8578cc61700c0140ed",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 4,
"info": "hurry",
"price": "46c48bec0d282018b9d167eef7711b2c",
"sdate": "None",
"edate": "None",
"id": null
}
],
"datas": {
"code": 1,
"data": [
{
"name": 1,
"info": "dsb12",
"price": "c4ca4238a0b923820dcc509a6f75849b",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 2,
"info": "d",
"price": "8fa14cdd754f91cc6554c9e71929cce7",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 3,
"info": "fk",
"price": "b25ffa68ad761f8578cc61700c0140ed",
"sdate": "None",
"edate": "None",
"id": null
},
{
"name": 4,
"info": "hurry",
"price": "46c48bec0d282018b9d167eef7711b2c",
"sdate": "None",
"edate": "None",
"id": null
}
]
}
}