```
開發環境:Virtualbox ubuntu 14.04
```
將貝殼物聯對應設備的ID和APIKEY替換后，直接make運行
```
/**
* Author:xlbtlmy
* blog:https://blog.csdn.net/u011958166
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <pthread.h>
char *welcome = "{\"M\":\"WELCOME TO BIGIOT\"}";
// ID:xxxx
// APIKEY:xxxxxxxxx
char *checkin = "{\"M\":\"checkin\",\"ID\":\"xxxx\",\"K\":\"xxxxxxxxx\"}\n";
char *beat = "{\"M\":\"beat\"}\n";
void *pthread_keepalive(void *);
void *pthread_handler(void *);
struct task {
pthread_t tidp;
int micro_seconds;
void * (*start_rtn)(void *);
};
struct task task_tbl[] = {
{ 0, 30000000, pthread_keepalive },
{ 0, 100000, pthread_handler },
};
int s;
int ret;
struct sockaddr_in bigiot_addr;
char buf[1024];
int main(int argc, char *argv[])
{
int i;
s = socket(AF_INET, SOCK_STREAM, 0);
if (s < 0) {
exit(-1);
}
bigiot_addr.sin_family = AF_INET;
bigiot_addr.sin_port = htons(8181);
bigiot_addr.sin_addr.s_addr = inet_addr("121.42.180.30");
ret = connect(s, (struct sockaddr_in *)&bigiot_addr, sizeof(bigiot_addr));
if (ret < 0) {
exit(-2);
}
memset(buf, 0, sizeof(buf));
ret = recv(s, buf, sizeof(buf), 0);
if (ret >= 0) {
printf("%s", buf);
}
#if 0
if (0 == memcmp(buf, welcome, sizeof(welcome))) {
printf("connect bigiot success!\n");
}
#endif
ret = send(s, checkin, strlen(checkin), 0);
if (ret < 0) {
printf("send error!\n");
exit(-3);
}
printf("%s", checkin);
ret = recv(s, buf, sizeof(buf), 0);
if (ret >= 0) {
printf("%s", buf);
}
for (i = 0; i < sizeof(task_tbl) / sizeof(task_tbl[0]); i ++) {
ret = pthread_create(&task_tbl[i].tidp,
NULL,
task_tbl[i].start_rtn,
&task_tbl[i].micro_seconds);
if (ret) {
printf("Create pthread error:%d\n", i);
exit(-1);
}
}
for (i = 0; i < sizeof(task_tbl) / sizeof(task_tbl[0]); i ++) {
pthread_join(task_tbl[i].tidp, NULL);
}
close(s);
return 0;
}
每30S發送一次以保持連接
void *pthread_keepalive(void *arg)
{
while (1) {
ret = send(s, beat, strlen(beat), 0);
if (ret < 0) {
printf("send error!\n");
exit(-3);
}
printf("%s", beat);
usleep(*(int *)arg);
}
return NULL;
}
打印接收到的數據
void *pthread_handler(void *arg)
{
while (1) {
memset(buf, 0, sizeof(buf));
ret = recv(s, buf, sizeof(buf), 0);
if (ret > 0) {
printf("%s", buf);
}
usleep(*(int *)arg);
}
return NULL;
}
在PC端模擬設備在線，可以做很多好玩的事情
例如，遠程控制設備執行一些指令，可以結合Python及shell使用
另外可以外接串口，控制單片機去做一些事情，不用外加其它模塊
后續會發出來一個python采用token獲取授權方式控制設備的上位機
有興趣的查看我的CSDN博客獲取源碼:https://blog.csdn.net/u011958166