主頁 > 作業系統 > 基于MQTT協議的云端proxy遠程登陸

基于MQTT協議的云端proxy遠程登陸

2020-10-07 22:58:30 作業系統

這篇檔案是建立在一下兩篇文章基礎上完成的 很多重復的內容不會在這章提到
https://www.cnblogs.com/y-c-y/p/11685405.html telnet協議相關
https://www.cnblogs.com/y-c-y/p/11686916.html MQTT協議相關

從這里開始就假設對MQTT和telnet協議的實作已經有一定的基礎了

這張時序圖是整個程式的時序 資料流向也是按章箭頭的流向來的

一下為實作代碼 部分的if 0是關掉了除錯用資訊

其中的 telnet.c telnet.h utils.c utils.h都已經在之前的文章中貼出來了 這次主要是控制部分

cloud_terninal.c

#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>
#include <string.h>

#define HOST "localhost"
#define PORT  1883
#define KEEP_ALIVE 60
#define MSG_MAX_SIZE  512
#define TOPIC_NUM 3

bool session = true;

const static char* topic[TOPIC_NUM] =
{
	"Gai爺:",
	"ycy ",
	"CCYY "
};

void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{
	
    if(message->payloadlen){
        printf(">%s %s", message->topic, (char *)message->payload);
		//printf("--sdfs----%ld-----------------\n",strlen((char *)message->payload));
		
    }else{
        printf("%s (null)\n", message->topic);
    }
    fflush(stdout);
}

void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    int i;
    if(!result){
        /* Subscribe to broker information topics on successful connect. */
        mosquitto_subscribe(mosq, NULL, "CCYY ", 2);
    }else{
        fprintf(stderr, "Connect failed\n");
    }
}

void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{
    int i;
    printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
    for(i=1; i<qos_count; i++){
        printf(", %d", granted_qos[i]);
    }
    printf("\n");
}

void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str)
{
    /* Pring all log messages regardless of level. */
    printf("%s\n", str);
}

int main()
{
    struct mosquitto *mosq = NULL;
	char buff[MSG_MAX_SIZE];
	
    //libmosquitto 庫初始化
    mosquitto_lib_init();
    //創建mosquitto客戶端
    mosq = mosquitto_new(NULL,session,NULL);
    if(!mosq){
        printf("create client failed..\n");
        mosquitto_lib_cleanup();
        return 1;
    }
    //設定回呼函式，需要時可使用
    //mosquitto_log_callback_set(mosq, my_log_callback);
    mosquitto_connect_callback_set(mosq, my_connect_callback);
    mosquitto_message_callback_set(mosq, my_message_callback);
    mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);
	

    //連接服務器
    if(mosquitto_connect(mosq, HOST, PORT, KEEP_ALIVE)){
        fprintf(stderr, "Unable to connect.\n");
        return 1;
    }
    //開啟一個執行緒，在執行緒里不停的呼叫 mosquitto_loop() 來處理網路資訊
    int loop = mosquitto_loop_start(mosq); 
    if(loop != MOSQ_ERR_SUCCESS)
    {
        printf("mosquitto loop error\n");
        return 1;
    }


	while(fgets(buff, MSG_MAX_SIZE, stdin) != NULL)
    {
        /*發布訊息*/
        mosquitto_publish(mosq,NULL,"ycy ",strlen(buff)+1,buff,0,0);
        memset(buff,0,sizeof(buff));
    }

    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

my_task.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <regex.h>
#include"mosquitto.h"
#include"utils.h"
#include"telnet.h"


//#define IP_ADDRESS   "127.0.0.1"
#define IP_PORT      23
#define SERV_PORT    3333
#define MAXLINE      1024

#define HOST "localhost"
#define PORT  1883
#define KEEP_ALIVE 60
#define MSG_MAX_SIZE  512
#define TOPIC_NUM 3
#define Key_to_Fun_Size 3

typedef struct sockaddr SA;
typedef void (*Fun)() ;

typedef struct key_word_to_fun
{
	char  key_word[MSG_MAX_SIZE];
	Fun   fun;
    void* arg1;	
}Key_to_Fun;


static void log_in_telnet();


bool session = true;
uint32 SOCKFD = 0;
char IP_ADDRESS[] = "xxx.xxx.xxx.xxx";

const static char* topic[TOPIC_NUM] =
{
	"Gai爺:",
	"ycy ",
	"CCYY "
};


static Key_to_Fun tab_Key_to_Fun[Key_to_Fun_Size] =
{
	{"telnet",log_in_telnet,0},
	{"login",log_in_telnet,0},
	{"password",log_in_telnet,0},
	//{NULL,NULL}
};

uint32 max(uint32 a, uint32 b)
{
	return (a>b?a:b);
}

void ERR_EXIT(char* s)
{
	perror(s);
	exit(EXIT_FAILURE);
}
void INFO_PRINT(char* s)
{
	printf("%s",s);
}

uint32 match_string(char *src,char* dst,char *pattern)
{
	
    //char *pattern1 = "^telnet";
	
	char errbuf[MAXLINE];
	//char match[MAXLINE];
	regex_t reg;
	int err,nm = 10;
	regmatch_t pmatch[nm];

	if(regcomp(&reg,pattern,REG_EXTENDED) < 0)
	{
		regerror(err,&reg,errbuf,sizeof(errbuf));
		printf("err:%s\n",errbuf);
		return 0;
	}
	err = regexec(&reg,src,nm,pmatch,0);
	if(err == REG_NOMATCH)
	{
		printf("no match\n");
		return 0;
	}
	else if(err)
	{
		regerror(err,&reg,errbuf,sizeof(errbuf));
		printf("err:%s\n",errbuf);
		return 0;
	}

	for(int i=0;i<10 && pmatch[i].rm_so!=-1;i++)
	{
		int len = pmatch[i].rm_eo - pmatch[i].rm_so;
		if(len)
		{
			memset(dst,'\0',MAXLINE);
			memcpy(dst,src + pmatch[i].rm_so,len);
			printf("%s\n",dst);
		}  
	}
	
	return 1;

}


static void log_in_telnet()
{
	uint32 sockfd,isReady=0;
	struct sockaddr_in servaddr;
	uint32 hname[128];
	
	sockfd = socket(AF_INET,SOCK_STREAM,0);
	bzero(&servaddr,sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_port = htons(IP_PORT);
	servaddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
	printf("servaddr: IP is %s, Port is %d\n",inet_ntoa(servaddr.sin_addr), ntohs(servaddr.sin_port));

	while(connect(sockfd,(SA*)&servaddr,sizeof(servaddr))){};
	SOCKFD = sockfd;
	printf("connect has been ready\n");
}

static void search_key_word_to_fun(struct mosquitto *mosq,char *s)
{
	int i = 0,j = 0;
	char temp[MSG_MAX_SIZE] = {};
	char match[MAXLINE];
	char pattern[] = "[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}";
	
	for(i =0 ;i< Key_to_Fun_Size;i++)
	{
		if(match_string(s,match,tab_Key_to_Fun[i].key_word))
		{
			if((i==0)&& (SOCKFD != 0))
			{
				printf("telnet has connect!! error command !!\n");
				return ;
			}
			else if((i==0)&& (SOCKFD == 0))
			{
			    if(match_string(s,match,pattern))
				{
					printf("---match------%s----------\n",match);
					for(j =0 ; match[j] != '\0' ;j++)
					{
						IP_ADDRESS[j] = match[j];
					}
					IP_ADDRESS[j] = '\0';
					tab_Key_to_Fun[i].fun();
				}
				else
				{
					/* do nothing */
					mosquitto_publish(mosq,NULL,"CCYY ",29,"you should put into your ip\n",0,0);
				}
				
			}
			else
			{
				tab_Key_to_Fun[i].fun();
			}
			return ;
		}
	}
	if((SOCKFD)&&(i != 0))
	{
		writen(SOCKFD,s,strlen(s));
	}
}

static void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{
	
    if(message->payloadlen){
        printf(">%s %s", message->topic, (char *)message->payload);
		search_key_word_to_fun(mosq,(char *)message->payload);
		
		
		//MQTT發啥 就往telnet發啥
    }else{
        printf("%s (null)\n", message->topic);
    }
    //fflush(stdout);
}

static void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    int i;
    if(!result){
        /* Subscribe to broker information topics on successful connect. */
        mosquitto_subscribe(mosq, NULL, "ycy ", 2);
    }else{
        fprintf(stderr, "Connect failed\n");
    }
}

static void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{
    int i;
    printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
    for(i=1; i<qos_count; i++){
        printf(", %d", granted_qos[i]);
    }
    printf("\n");
}

static void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str)
{
    /* Pring all log messages regardless of level. */
    printf("%s\n", str);
}
/* 此處用這個函式代替之前的writen函式，是因為真正的telnet協議是一字符一字符發送的字串結尾以'\r'結束 */
void telnet_client_send_msg(int fd, const void *vptr, size_t n)
{
	char endFlag = '\r';
	uint32 i =0;
	void * pStr = vptr;
	
	for(i = 0 ; i < n ; i++,pStr++ )
	{
		writen(fd,pStr,1);
	}
	if(*(uint8 *)pStr == '\0')
	{
		writen(fd,&endFlag,1);
	}
	else
	{
		writen(fd,&endFlag,1);
	}
}

void wait_message_from_telnet(struct mosquitto *mosq,FILE *fp,uint32 sockfd)
{
	uint32 maxfdp1,nready;//stdineof;
	fd_set rset;
	uint8 buf[MAXLINE];
	uint8 respbuff[MAXLINE] = {0};;
	uint32 resplen;
	uint32 n;
	uint8 echo_cmd[] = {0xff,0xfb,0x01};
	//stdineof = 0;
	FD_ZERO(&rset);
	writen(sockfd,echo_cmd,3);
	
	for(;;)
	{
		//if(stdineof == 0)
		FD_SET(fileno(fp),&rset);
		FD_SET(sockfd,&rset);
		maxfdp1 = max(fileno(fp),sockfd)+1;
		nready = select(maxfdp1,&rset,NULL,NULL,NULL);
		
		if(nready < 0)
		{
			ERR_EXIT("ERROR!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
		}
		
		if(FD_ISSET(sockfd,&rset))
		{
			memset(buf,0,MAXLINE);
			if((n = read(sockfd,buf,MAXLINE))==0)
			{
				ERR_EXIT("str_cli:server termination prematurely");
			}
			buf[n] = '\0';
			//printf("FD_ISSET(sockfd,&rset)------11------%s----22----------------\n",buf);
			
			if(buf[0] == IAC)
			{
				memset(respbuff,0,MAXLINE);
				resplen = get_every_frame(buf,n,respbuff,MAXLINE);
				writen(sockfd,respbuff,resplen);
			}
			else
			{
				telnet_client_send_msg(fileno(stdout),(char *)buf,n);//當資料比較大的時候 會造成發給cloud資料錯位
				//printf("------------2------------\n");
				mosquitto_publish(mosq,NULL,"CCYY ",strlen(buf)+1,buf,0,0);
				//printf("------------3------------\n");
				memset(buf,0,MAXLINE);
			}
			
			//writen(fileno(stdout),buf,n);
		}
		if(FD_ISSET(fileno(fp),&rset))
		{
			memset(buf,0,MAXLINE);
			if((n = readline(fileno(fp),(char *)buf,MAXLINE)) == 0)
			{
				//stdineof = 1;//此時碰到EOF 并且馬上要發生FIN序列 所以標準輸入不可讀了
				shutdown(sockfd,SHUT_WR);
				FD_CLR(fileno(fp),&rset);
				INFO_PRINT("nothing input!");
				continue;
			}
			else if(n >0)
			{
				/* do nothing */
			}
			else
			{
				ERR_EXIT("some error occurred ");
			}
			//printf("FD_ISSET(fileno(fp),&rset)----%d--\n",n);
			//memset(buf,0,MAXLINE);
			telnet_client_send_msg(sockfd,(char *)buf,n);
			//send_message_to_cloud(sockfd,(char *)buf,n);
		}
	}
}

void test()
{
	//unsigned char s[] = 15042b58;
	//printf("+++++++++++++++++++++++++++++++\n",s);
	printf("+++++++++++++++++++++++++++++++\n");
	putchar(0x15);
	putchar(0x04);
	putchar(0x2b);
	putchar(0x58);
	printf("+++++++++++++++++++++++++++++++\n");
}

int main()
{
    struct mosquitto *mosq = NULL;
	char buff[MSG_MAX_SIZE];
	
	
	test();
    //libmosquitto 庫初始化
    mosquitto_lib_init();
    //創建mosquitto客戶端
    mosq = mosquitto_new(NULL,session,NULL);
    if(!mosq){
        printf("create client failed..\n");
        mosquitto_lib_cleanup();
        return 1;
    }
    //設定回呼函式，需要時可使用
    //mosquitto_log_callback_set(mosq, my_log_callback);
    mosquitto_connect_callback_set(mosq, my_connect_callback);
    mosquitto_message_callback_set(mosq, my_message_callback);
    mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);
	

    //連接服務器
    if(mosquitto_connect(mosq, HOST, PORT, KEEP_ALIVE)){
        fprintf(stderr, "Unable to connect.\n");
        return 1;
    }
    //開啟一個執行緒，在執行緒里不停的呼叫 mosquitto_loop() 來處理網路資訊
    int loop = mosquitto_loop_start(mosq); 
    if(loop != MOSQ_ERR_SUCCESS)
    {
        printf("mosquitto loop error\n");
        return 1;
    }

	while(!SOCKFD){};
	wait_message_from_telnet(mosq,stdin,SOCKFD);
	

    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

makefile


#不是系統默認庫 要記得添加連接選項

all:My_task
	@echo ""
	@echo "This is My_task compile......."
	@echo ""
	
My_task: utils.o telnet.o my_task.o Cloud
	gcc -g -o My_task my_task.o utils.o telnet.o -lmosquitto -lpthread

Cloud: utils.o telnet.o cloud_terminal.o
	gcc -g -o Cloud cloud_terminal.c -lmosquitto -lpthread
	
my_task.o:my_task.c utils.h telnet.h
	gcc -g -c my_task.c
	
cloud_terminal.o:cloud_terminal.c utils.h telnet.h
	gcc -g -c cloud_terminal.c	
	
utils.o:utils.c utils.h
	gcc -g -c utils.c 
	
telnet.o:telnet.c telnet.h
	gcc -g -c telnet.c
	
clean :
	-rm my_task.o cloud_terminal.o utils.o telnet.o Cloud My_task

運行情況：

為了方便除錯 在mytask的程式中我也列印出來登錄資訊

=====================================================================================================

以上的程式有一點不足之處是默認登錄我自己的IP 不能從外界獲取IP 一下的程式再這個基礎上有所改動 可以使用“telnet 127.0.0.1”這種命令登錄進去，

添加的部分是使用了正則運算式，包含頭檔案#include <regex.h> 關于這個C語言的正則運算式的用法在此不詳說 如果要匹配中文請慎重使用 據說對中文支持的不是很好

我在這里遇見的問題是

我想匹配“xxx.xxx.xxx.xxx”使用的可以識別模式串是char pattern[] = "[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}";這個是沒有問題的

但是最開始我使用的是char pattern[] = "\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}"; 以上這兩種用法在python中是相同的結果 但是第二種情況在C語言中不適用

my_task.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <regex.h>
#include"mosquitto.h"
#include"utils.h"
#include"telnet.h"


//#define IP_ADDRESS   "127.0.0.1"
#define IP_PORT      23
#define SERV_PORT    3333
#define MAXLINE      1024

#define HOST "localhost"
#define PORT  1883
#define KEEP_ALIVE 60
#define MSG_MAX_SIZE  512
#define TOPIC_NUM 3
#define Key_to_Fun_Size 3

typedef struct sockaddr SA;
typedef void (*Fun)() ;

typedef struct key_word_to_fun
{
	char  key_word[MSG_MAX_SIZE];
	Fun   fun;
    void* arg1;	
}Key_to_Fun;


static void log_in_telnet();


bool session = true;
uint32 SOCKFD = 0;
char IP_ADDRESS[] = "xxx.xxx.xxx.xxx";

const static char* topic[TOPIC_NUM] =
{
	"Gai爺:",
	"ycy ",
	"CCYY "
};


static Key_to_Fun tab_Key_to_Fun[Key_to_Fun_Size] =
{
	{"telnet",log_in_telnet,0},
	{"login",log_in_telnet,0},
	{"password",log_in_telnet,0},
	//{NULL,NULL}
};

uint32 max(uint32 a, uint32 b)
{
	return (a>b?a:b);
}

void ERR_EXIT(char* s)
{
	perror(s);
	exit(EXIT_FAILURE);
}
void INFO_PRINT(char* s)
{
	printf("%s",s);
}

uint32 match_string(char *src,char* dst,char *pattern)
{
	
    //char *pattern1 = "^telnet";
	
	char errbuf[MAXLINE];
	//char match[MAXLINE];
	regex_t reg;
	int err,nm = 10;
	regmatch_t pmatch[nm];

	if(regcomp(&reg,pattern,REG_EXTENDED) < 0)
	{
		regerror(err,&reg,errbuf,sizeof(errbuf));
		printf("err:%s\n",errbuf);
		return 0;
	}
	err = regexec(&reg,src,nm,pmatch,0);
	if(err == REG_NOMATCH)
	{
		printf("no match\n");
		return 0;
	}
	else if(err)
	{
		regerror(err,&reg,errbuf,sizeof(errbuf));
		printf("err:%s\n",errbuf);
		return 0;
	}

	for(int i=0;i<10 && pmatch[i].rm_so!=-1;i++)
	{
		int len = pmatch[i].rm_eo - pmatch[i].rm_so;
		if(len)
		{
			memset(dst,'\0',MAXLINE);
			memcpy(dst,src + pmatch[i].rm_so,len);
			printf("%s\n",dst);
		}  
	}
	
	return 1;

}


static void log_in_telnet()
{
	uint32 sockfd,isReady=0;
	struct sockaddr_in servaddr;
	uint32 hname[128];
	
	sockfd = socket(AF_INET,SOCK_STREAM,0);
	bzero(&servaddr,sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_port = htons(IP_PORT);
	servaddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
	printf("servaddr: IP is %s, Port is %d\n",inet_ntoa(servaddr.sin_addr), ntohs(servaddr.sin_port));

	while(connect(sockfd,(SA*)&servaddr,sizeof(servaddr))){};
	SOCKFD = sockfd;
	printf("connect has been ready\n");
}

static void search_key_word_to_fun(struct mosquitto *mosq,char *s)
{
	int i = 0,j = 0;
	char temp[MSG_MAX_SIZE] = {};
	char match[MAXLINE];
	char pattern[] = "[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}";
	
	for(i =0 ;i< Key_to_Fun_Size;i++)
	{
		if(match_string(s,match,tab_Key_to_Fun[i].key_word))
		{
			if((i==0)&& (SOCKFD != 0))
			{
				printf("telnet has connect!! error command !!\n");
				return ;
			}
			else if((i==0)&& (SOCKFD == 0))
			{
			    if(match_string(s,match,pattern))
				{
					printf("---match------%s----------\n",match);
					for(j =0 ; match[j] != '\0' ;j++)
					{
						IP_ADDRESS[j] = match[j];
					}
					IP_ADDRESS[j] = '\0';
					tab_Key_to_Fun[i].fun();
				}
				else
				{
					/* do nothing */
					mosquitto_publish(mosq,NULL,"CCYY ",29,"you should put into your ip\n",0,0);
				}
				
			}
			else
			{
				tab_Key_to_Fun[i].fun();
			}
			return ;
		}
	}
	if((SOCKFD)&&(i != 0))
	{
		writen(SOCKFD,s,strlen(s));
	}
}

static void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{
	
    if(message->payloadlen){
        printf(">%s %s", message->topic, (char *)message->payload);
		search_key_word_to_fun(mosq,(char *)message->payload);
		
		
		//MQTT發啥 就往telnet發啥
    }else{
        printf("%s (null)\n", message->topic);
    }
    //fflush(stdout);
}

static void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    int i;
    if(!result){
        /* Subscribe to broker information topics on successful connect. */
        mosquitto_subscribe(mosq, NULL, "ycy ", 2);
    }else{
        fprintf(stderr, "Connect failed\n");
    }
}

static void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{
    int i;
    printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
    for(i=1; i<qos_count; i++){
        printf(", %d", granted_qos[i]);
    }
    printf("\n");
}

static void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str)
{
    /* Pring all log messages regardless of level. */
    printf("%s\n", str);
}

void wait_message_from_telnet(struct mosquitto *mosq,FILE *fp,uint32 sockfd)
{
	uint32 maxfdp1,nready;//stdineof;
	fd_set rset;
	uint8 buf[MAXLINE];
	uint8 respbuff[MAXLINE] = {0};;
	uint32 resplen;
	uint32 n;
	uint8 echo_cmd[] = {0xff,0xfb,0x01};
	//stdineof = 0;
	FD_ZERO(&rset);
	writen(sockfd,echo_cmd,3);
	
	for(;;)
	{
		//if(stdineof == 0)
		FD_SET(fileno(fp),&rset);
		FD_SET(sockfd,&rset);
		maxfdp1 = max(fileno(fp),sockfd)+1;
		nready = select(maxfdp1,&rset,NULL,NULL,NULL);
		
		if(nready < 0)
		{
			ERR_EXIT("ERROR!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
		}
		
		if(FD_ISSET(sockfd,&rset))
		{
			memset(buf,0,MAXLINE);
			if((n = read(sockfd,buf,MAXLINE))==0)
			{
				ERR_EXIT("str_cli:server termination prematurely");
			}
			buf[n] = '\0';
			//printf("FD_ISSET(sockfd,&rset)------11------%s----22----------------\n",buf);
			
			if(buf[0] == IAC)
			{
				memset(respbuff,0,MAXLINE);
				resplen = get_every_frame(buf,n,respbuff,MAXLINE);
				writen(sockfd,respbuff,resplen);
			}
			else
			{
				writen(fileno(stdout),(char *)buf,n);//當資料比較大的時候 會造成發給cloud資料錯位
				//printf("------------2------------\n");
				mosquitto_publish(mosq,NULL,"CCYY ",strlen(buf)+1,buf,0,0);
				//printf("------------3------------\n");
				memset(buf,0,MAXLINE);
			}
			
			//writen(fileno(stdout),buf,n);
		}
		if(FD_ISSET(fileno(fp),&rset))
		{
			memset(buf,0,MAXLINE);
			if((n = readline(fileno(fp),(char *)buf,MAXLINE)) == 0)
			{
				//stdineof = 1;//此時碰到EOF 并且馬上要發生FIN序列 所以標準輸入不可讀了
				shutdown(sockfd,SHUT_WR);
				FD_CLR(fileno(fp),&rset);
				INFO_PRINT("nothing input!");
				continue;
			}
			else if(n >0)
			{
				/* do nothing */
			}
			else
			{
				ERR_EXIT("some error occurred ");
			}
			//printf("FD_ISSET(fileno(fp),&rset)----%d--\n",n);
			//memset(buf,0,MAXLINE);
			writen(sockfd,(char *)buf,n);
			//send_message_to_cloud(sockfd,(char *)buf,n);
		}
	}
}

int main()
{
    struct mosquitto *mosq = NULL;
	char buff[MSG_MAX_SIZE];
	
    //libmosquitto 庫初始化
    mosquitto_lib_init();
    //創建mosquitto客戶端
    mosq = mosquitto_new(NULL,session,NULL);
    if(!mosq){
        printf("create client failed..\n");
        mosquitto_lib_cleanup();
        return 1;
    }
    //設定回呼函式，需要時可使用
    //mosquitto_log_callback_set(mosq, my_log_callback);
    mosquitto_connect_callback_set(mosq, my_connect_callback);
    mosquitto_message_callback_set(mosq, my_message_callback);
    mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);
	

    //連接服務器
    if(mosquitto_connect(mosq, HOST, PORT, KEEP_ALIVE)){
        fprintf(stderr, "Unable to connect.\n");
        return 1;
    }
    //開啟一個執行緒，在執行緒里不停的呼叫 mosquitto_loop() 來處理網路資訊
    int loop = mosquitto_loop_start(mosq); 
    if(loop != MOSQ_ERR_SUCCESS)
    {
        printf("mosquitto loop error\n");
        return 1;
    }

	while(!SOCKFD){};
	wait_message_from_telnet(mosq,stdin,SOCKFD);
	

    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

一下是程式運行情況

總結：
1.gdb除錯方法十分有效 應當加強掌握
2.在除錯程序中出現程序式不穩定的情況 但是很偶然 根據那幾次的分析結果 可能是讀寫緩沖區的問題 比如發來的資料很快并且多 這時候讀資料的速度跟不上 就會出現顯示出現問題 這個方面我不是很了解 以后要了解一下這方面的知識

以上

轉載請註明出處，本文鏈接：https://www.uj5u.com/caozuo/161996.html

標籤：Linux

上一篇：[轉]linux多命令的順序執行

下一篇：虛擬 IP 設為靜態 IP

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • CA和證書

    1、在 CentOS7 中使用 gpg 創建 RSA 非對稱密鑰對 gpg --gen-key #Centos上生成公鑰/密鑰對（存放在家目錄.gnupg/） 2、將 CentOS7 匯出的公鑰，拷貝到 CentOS8 中，在 CentOS8 中使用 CentOS7 的公鑰加密一個檔案 gpg -a ......

    uj5u.com 2020-09-10 00:09:53 more
  • Kubernetes K8S之資源控制器Job和CronJob詳解

    Kubernetes的資源控制器Job和CronJob詳解與示例 ......

    uj5u.com 2020-09-10 00:10:45 more
  • VMware下安裝CentOS

    VMware下安裝CentOS 一、軟硬體準備 1 Centos鏡像準備 1.1 CentOS鏡像下載地址 下載地址 1.2 CentOS鏡像下載程序 點擊下載地址進入如下圖的網站，選擇需要下載的版本，這里選擇的是Centos8，點擊如圖所示。 決定選擇Centos8后，選擇想要的鏡像源進行下載，此 ......

    uj5u.com 2020-09-10 00:12:10 more
  • 如何使用Grep命令查找多個字串

    如何使用Grep 命令查找多個字串 大家好，我是良許！ 今天向大家介紹一個非常有用的技巧，那就是使用 grep 命令查找多個字串。 簡單介紹一下，grep 命令可以理解為是一個功能強大的命令列工具，可以用它在一個或多個輸入檔案中搜索與正則運算式相匹配的文本，然后再將每個匹配的文本用標準輸出的格式 ......

    uj5u.com 2020-09-10 00:12:28 more
  • git配置http代理

    git配置http代理 經常遇到克隆 github 慢的問題，這里記錄一下幾種配置 git 代理的方法，解決 clone github 過慢。 目錄 git配置代理 git單獨配置github代理 git配置全域代理 配置終端環境變數 git配置代理 主要使用 git config 命令 git單獨 ......

    uj5u.com 2020-09-10 00:12:33 more
  • Linux npm install 裝包時提示Error EACCES permission denied解

    npm install 裝包時提示Error EACCES permission denied解決辦法 ......

    uj5u.com 2020-09-10 00:12:53 more
  • Centos 7下安裝nginx，使用yum install nginx，提示沒有可用的軟體包

    Centos 7下安裝nginx，使用yum install nginx，提示沒有可用的軟體包。 18 (flaskApi) [root@67 flaskDemo]# yum -y install nginx 19 已加載插件：fastestmirror, langpacks 20 Loading ......

    uj5u.com 2020-09-10 00:13:13 more
  • Linux查看服務器暴力破解ssh IP

    在公網的服務器上經常遇到別人爆破你服務器的22埠，用來挖礦或者干其他嘿嘿嘿的事情~ 這種情況下正確的做法是： 修改默認ssh的22埠 使用設定密鑰登錄或者白名單ip登錄 建議服務器密碼為復雜密碼 創建普通用戶登錄服務器（root權限過大） 建立堡壘機，實作統一管理服務器 統計爆破IP [root ......

    uj5u.com 2020-09-10 00:13:17 more
  • CentOS 7系統常見快捷鍵操作方式

    Linux系統中一些常見的快捷方式，可有效提高操作效率，在某些時刻也能避免操作失誤帶來的問題。 ......

    uj5u.com 2020-09-10 00:13:31 more
  • CentOS 7作業系統目錄結構介紹

    作業系統存在著大量的資料檔案資訊，相應檔案資訊會存在于系統相應目錄中，為了更好的管理資料資訊，會將系統進行一些目錄規劃，不同目錄存放不同的資源。 ......

    uj5u.com 2020-09-10 00:13:35 more
最新发布
  • vim的常用命令

    Vim的6種基本模式 1. 普通模式在普通模式中，用的編輯器命令，比如移動游標，洗掉文本等等。這也是Vim啟動后的默認模式。這正好和許多新用戶期待的操作方式相反（大多數編輯器默認模式為插入模式）。 2. 插入模式在這個模式中，大多數按鍵都會向文本緩沖中插入文本。大多數新用戶希望文本編輯器編輯程序中一 ......

    uj5u.com 2023-04-20 08:43:21 more
  • vim的常用命令

    Vim的6種基本模式 1. 普通模式在普通模式中，用的編輯器命令，比如移動游標，洗掉文本等等。這也是Vim啟動后的默認模式。這正好和許多新用戶期待的操作方式相反（大多數編輯器默認模式為插入模式）。 2. 插入模式在這個模式中，大多數按鍵都會向文本緩沖中插入文本。大多數新用戶希望文本編輯器編輯程序中一 ......

    uj5u.com 2023-04-20 08:42:36 more
  • docker學習

    ###Docker概述 真實專案部署環境可能非常復雜，傳統發布專案一個只需要一個jar包，運行環境需要單獨部署。而通過Docker可將jar包和相關環境（如jdk，redis，Hadoop...）等打包到docker鏡像里，將鏡像發布到Docker倉庫，部署時下載發布的鏡像，直接運行發布的鏡像即可。 ......

    uj5u.com 2023-04-19 09:26:53 more
  • 設定Windows主機的瀏覽器為wls2的默認瀏覽器

    這里以Chrome為例。 1. 準備作業 wsl是可以使用Windows主機上安裝的exe程式，出于安全考慮，默認情況下改功能是無法使用。要使用的話，終端需要以管理員權限啟動。 我這里以Windows Terminal為例，介紹如何默認使用管理員權限打開終端，具體操作如下圖所示： 2. 操作 wsl ......

    uj5u.com 2023-04-19 09:25:49 more
  • docker學習

    ###Docker概述 真實專案部署環境可能非常復雜，傳統發布專案一個只需要一個jar包，運行環境需要單獨部署。而通過Docker可將jar包和相關環境（如jdk，redis，Hadoop...）等打包到docker鏡像里，將鏡像發布到Docker倉庫，部署時下載發布的鏡像，直接運行發布的鏡像即可。 ......

    uj5u.com 2023-04-19 09:19:04 more
  • Linux學習筆記

    IP地址和主機名 IP地址 ifconfig可以用來查詢本機的IP地址，如果不能使用，可以通過install net-tools安裝。 Centos系統下ens33表示主網卡；inet后表示IP地址；lo表示本地回環網卡； 127.0.0.1表示代指本機；0.0.0.0可以用于代指本機，同時在放行設 ......

    uj5u.com 2023-04-18 06:52:01 more
  • 解決linux系統的kdump服務無法啟動的問題

    問題：專案麒麟系統服務器的kdump服務無法啟動，沒有相關日志無法定位問題。 1、查看服務狀態是關閉的，重啟系統也無法啟動 systemctl status kdump 2、修改grub引數，修改“crashkernel”為“512M（有的機器數值太大太小都會導致報錯，建議從128M開始試，或者加個 ......

    uj5u.com 2023-04-12 09:59:50 more
  • 解決linux系統的kdump服務無法啟動的問題

    問題：專案麒麟系統服務器的kdump服務無法啟動，沒有相關日志無法定位問題。 1、查看服務狀態是關閉的，重啟系統也無法啟動 systemctl status kdump 2、修改grub引數，修改“crashkernel”為“512M（有的機器數值太大太小都會導致報錯，建議從128M開始試，或者加個 ......

    uj5u.com 2023-04-12 09:59:01 more
  • 你是不是暴露了？

    作者：袁首京 原創文章，轉載時請保留此宣告，并給出原文連接。 如果您是計算機相關從業人員，那么應該經歷不止一次網路安全專項檢查了，你肯定是收到過資訊系統技術檢測報告，要求你加強風險監測，確保你提供的系統服務堅實可靠了。 沒檢測到問題還好，檢測到問題的話，有些處理起來還是挺麻煩的，尤其是線上正在運行的 ......

    uj5u.com 2023-04-05 16:52:56 more
  • 細節拉滿，80 張圖帶你一步一步推演 slab 記憶體池的設計與實作

    1. 前文回顧 在之前的幾篇記憶體管理系列文章中，筆者帶大家從宏觀角度完整地梳理了一遍 Linux 記憶體分配的整個鏈路，本文的主題依然是記憶體分配，這一次我們會從微觀的角度來探秘一下 Linux 內核中用于零散小記憶體塊分配的記憶體池 —— slab 分配器。 在本小節中，筆者還是按照以往的風格先帶大家簡單 ......

    uj5u.com 2023-04-05 16:44:11 more

Copyright © 2010-2020 有解無憂