From 602442ecedf17800cddfdae188b05b40345cb011 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 12 六月 2020 12:08:46 +0800
Subject: [PATCH] version
---
service/test_client.c | 103 +++++++++++++++++++++++++++++++++++++++------------
1 files changed, 79 insertions(+), 24 deletions(-)
diff --git a/service/client.c b/service/test_client.c
similarity index 68%
rename from service/client.c
rename to service/test_client.c
index 170e788..368f641 100644
--- a/service/client.c
+++ b/service/test_client.c
@@ -43,6 +43,54 @@
}
+void doGetDeviceInfo(nng_socket sock) {
+ char * buf = NULL;
+ int rv;
+ size_t sz;
+ Json::Value request;
+ request["method"] = "getDeviceInfo";
+ Json::Value arguments;
+ arguments["loginUUID"] = "1";
+ request["arguments"]= arguments;
+
+ std::string str = request.toStyledString();
+
+ if ((rv = nng_send(sock, strdup(str.c_str()), str.length(), 0)) != 0) {
+ fatal("nng_send", rv);
+ }
+ if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {
+ fatal("nng_recv", rv);
+ }
+ std::cout << buf;
+ nng_free(buf, sz);
+
+
+}
+
+void doLogout(nng_socket sock) {
+ char * buf = NULL;
+ int rv;
+ size_t sz;
+ Json::Value request;
+ request["method"] = "logout";
+ Json::Value arguments;
+ arguments["loginUUID"] = "1";
+ request["arguments"]= arguments;
+
+ std::string str = request.toStyledString();
+
+ if ((rv = nng_send(sock, strdup(str.c_str()), str.length(), 0)) != 0) {
+ fatal("nng_send", rv);
+ }
+ if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {
+ fatal("nng_recv", rv);
+ }
+ std::cout << buf;
+ nng_free(buf, sz);
+
+
+}
+
void doDownloadByTime(nng_socket sock) {
char * buf = NULL;
int rv;
@@ -93,8 +141,10 @@
}
+
+
int
-client(const char *method)
+runclient(const char *method)
{
nng_socket sock;
int rv;
@@ -105,18 +155,35 @@
if ((rv = nng_dial(sock, url, NULL, 0)) != 0) {
fatal("nng_dial", rv);
}
- printf("CLIENT: SENDING DATE REQUEST\n");
+ //printf("CLIENT: SENDING DATE REQUEST\n");
if (strcmp(method, "login") == 0) {
doLogin(sock);
} else if (strcmp(method, "download") == 0) {
doDownloadByTime(sock);
+ } else if (strcmp(method, "getDeviceInfo") == 0) {
+ doGetDeviceInfo(sock);
+ } else if (strcmp(method, "logout") == 0) {
+ doLogout(sock);
} else {
printf("Don't surpport %s \n", method);
}
nng_close(sock);
return (0);
+}
+
+
+void *client(void *vargp) {
+ char method[1024]={0};
+ for(;;) {
+ printf("===璇疯緭鍏ヨ姹傛柟娉曪細\n");
+ scanf("%s", method);
+ if (strcmp(method, "q") == 0) {
+ exit(0);
+ }
+ runclient(method);
+ }
}
int
@@ -137,7 +204,9 @@
if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {
fatal("nng_recv", rv);
}
+ printf("===Received Call Back===\n");
std::cout << buf << std::endl;
+ nng_free(buf, sz);
Json::Value response;
response["code"] = 0;
@@ -146,21 +215,7 @@
if (rv != 0) {
fatal("nng_send", rv);
}
- // if ((sz == sizeof(uint64_t)) &&
- // ((GET64(buf, val)) == DATECMD)) {
- // time_t now;
- // printf("SERVER: RECEIVED DATE REQUEST\n");
- // now = time(&now);
- // printf("SERVER: SENDING DATE: ");
- // showdate(now);
-
- // // Reuse the buffer. We know it is big enough.
- // PUT64(buf, (uint64_t) now);
-
- // continue;
- // }
- // Unrecognized command, so toss the buffer.
- //nng_free(buf, sz);
+
}
}
@@ -168,14 +223,14 @@
int
main(const int argc, const char **argv)
{
- if ((argc > 1)) {
- client(argv[1]);
- server();
- }
+
// std::string str("123");
// char *str2="123";
// printf("str length %d, %d\n", str.length(), strlen(str2));
-
- fprintf(stderr, "Usage: client <method> ...\n");
- return (1);
+ pthread_t tid;
+ pthread_create(&tid, NULL, client, NULL);
+
+ server();
+ return 0;
+
}
\ No newline at end of file
--
Gitblit v1.8.0