电子词典

项目要求:

1.登录注册功能,不能重复登录,重复注册。用户信息也存储在数据库中。

2.单词查询功能

3.历史记录功能,存储单词,意思,以及查询时间,存储在数据库

4.基于TCP,支持多客户端连接

5.采用数据库保存用户信息与历史记录

6.将dict.txt的数据导入到数据库中保存。

7.返回上级或者退出客户端后,该账户退出登录

流程图:

 服务端:

#include<myhead.h>
#define ERR_MSG(msg){\
	fprintf(stderr,"__%d__",__LINE__);\
	perror(msg);\
}
#define PORT 8888
#define IP "192.168.125.58"

#define  NOTLOGIN 0
#define  LOGIN    1
#define  YES      2
#define  NO       3
#define  REGISTER 4
#define  WORD     5
#define  HISTORY  6

void update_user(sqlite3 *db, char* username);
sqlite3* create();
int do_insert(sqlite3* db);

void* callback(void* arg);
struct msg
{
	int newfd;
	struct sockaddr_in cin;
	sqlite3* db;
};


int main(int argc, const char *argv[])
{
	//创建并打开数据库
	sqlite3* db;
	db = create();

	//创建流式套接字
	int sfd = socket(AF_INET,SOCK_STREAM,0);
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}
	//允许端口快速重用
	int reuse = 1;
	if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0)
	{
		ERR_MSG("setsockopt");
		return -1;
	}
	printf("允许端口快速重用成功\n");

	//填充ip端口地址信息
	struct sockaddr_in sin;
	sin.sin_family 		=AF_INET;
	sin.sin_port  		=htons(PORT);
	sin.sin_addr.s_addr =inet_addr(IP);

	//绑定服务器的ip端口和地址,必须绑定
	if(bind(sfd,(struct sockaddr*)&sin, sizeof(sin))<0)
	{
		ERR_MSG("bind");
		return -1;
	}
	printf("bind success\n");
	//套接字设置为被动监听状态
	if(listen(sfd,128)<0)
	{
		ERR_MSG("listen");
		return -1;
	}
	printf("listen success\n");

	struct sockaddr_in cin;
	int addrlen = sizeof(cin);
	pthread_t tid;
	struct msg info;

	while(1)
	{
		//循环连接客户端获取newfd	
		int newfd=accept(sfd, (struct sockaddr*)&cin, &addrlen);
		if(newfd<0)
		{
			ERR_MSG("accept");
			return -1;
		}
		printf("newfd=%d\n", newfd);
 
		info.newfd = newfd;
		info.cin = cin;
		info.db = db;
		//创建新线程
		pthread_create(&tid, NULL, callback, (void*)&info);
	
		pthread_detach(tid);//设置为分离态
	}
	close(sfd);
	return 0;
}

void* callback(void* arg)
{
	//接收传参来的数据
	struct msg info=*(struct msg*)arg;
	int newfd = info.newfd;
	struct sockaddr_in cin=info.cin;
	//数据库首地址
	sqlite3* db = info.db;
	char buf[128]="";
	ssize_t res=0;
	//定义用户名全局变量,不同case语句都可使用
	char username[20]="";
	char password[20]="";
	char choose;

	printf("[port: %d ip: %s]用户连接\n",ntohs(cin.sin_port), inet_ntoa(cin.sin_addr));

	while(1)
	{
		bzero(buf, sizeof(buf));

		//首次接收客户端信息
		res=recv(newfd, buf, sizeof(buf), 0);
		if(res<0)
		{
			ERR_MSG("recv");
			break;
		}
		else if(0==res)
		{
			fprintf(stderr, "newfd=%d客户端下线\n", newfd);
			update_user(db, username);
			break;
		}

		//拆解buf信息
		choose = *buf;

		switch(choose)
		{
			//注册
		case REGISTER:

			{
				bzero(username, sizeof(username));
				strcpy(username, buf+1);
				strcpy(password, buf+1+strlen(username)+1);
				bzero(buf, sizeof(buf));
				char* errmsg = NULL;
				char** pres;
				int row, column;
				//查找是否存在用户
				sprintf(buf, "select* from user where username=\"%s\";", username);
				if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
				{
					  fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
                      return NULL;
				}

				if(row != 1)
				{
					//不存在该用户则可以注册
					//发送YES给客户端
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", YES, 0);
					if(send(newfd, buf, sizeof(buf), 0)<0)
					{
						perror("send");
						return NULL;
					}
					bzero(buf, sizeof(buf));
					//组插入语句将用户插入数据库
					sprintf(buf, "insert into user values(\"%s\",\"%s\", %d);",username, password,NOTLOGIN);
					if(sqlite3_exec(db, buf, NULL, NULL, &errmsg) != SQLITE_OK)
					{
						fprintf(stderr, "__%d__sqlite3_ex: %s\n", __LINE__, errmsg);
						return NULL;
					}
					printf("存入数据库成功\n");
				}
				//用户已存在
				else
				{
					//用户已经存在不可以注册
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", NO, 0);
					//发送no
					if(send(newfd, buf, sizeof(buf), 0)<0)
					{
						perror("send");
						return NULL;
					}
				}
				//释放堆区空间
				sqlite3_free_table(pres);
				pres = NULL;
			}break;

		case LOGIN:
			{
				bzero(password, sizeof(password));
				bzero(username, sizeof(username));
				
				//提取用户名和密码
				strcpy(username, buf+1);
				strcpy(password, buf+1+strlen(username)+1);
				bzero(buf, sizeof(buf));
				char* errmsg = NULL;
				char** pres;
				int row=0, column=0;
				
				//查找账户是否存在
				sprintf(buf, "select* from user where username=\"%s\" and password=\"%s\";", username, password);
				if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
				{
					fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
					return NULL;
				}
				
				//账户存在
				if(row == 1)
				{
					bzero(buf, sizeof(buf));

					sprintf(buf, "select* from user where username=\"%s\" and password=\"%s\" and stat=%d;", username, password, NOTLOGIN);
					if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
					{
						fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
						return NULL;
					}
					//账户存在且若果不为登录状态则可以登录

					if(row == 1)
					{
						bzero(buf, sizeof(buf));
						//发送YES
						sprintf(buf, "%c%c", YES, 0);
						if(send(newfd, buf, 2, 0)<0)
						{
							perror("send");
							return NULL;
						}
						//修改登录装填值为登录状态
						bzero(buf, sizeof(buf));
						sprintf(buf, "update user set stat=%d where username=\"%s\";", LOGIN, username);
						if(sqlite3_exec(db, buf, NULL, NULL, &errmsg) != SQLITE_OK)

						{
							fprintf(stderr, "__%d__sqlite3_ex: %s\n", __LINE__, errmsg);
							return NULL;
						}
						printf("登录成功\n");
						break;
					}
					//否则告诉客户端已经登录
					else
					{
						bzero(buf, sizeof(buf));
						sprintf(buf, "%c%c", LOGIN, 0);
						if(send(newfd, buf, 2, 0)<0)
						{
							perror("send");
							return NULL;
						}
					}

				}
				//账号不存在或者密码错误
				else
				{
					bzero(buf, sizeof(buf));
					//向客户端发送NO说明密码错误或者账户不存在
					sprintf(buf, "%c%c", NO, 0);
					if(send(newfd, buf, 2, 0)<0)
					{
						perror("send");
						return NULL;
					}
				}
				sqlite3_free_table(pres);
				pres=NULL;
			}break;

		//查找单词
		case WORD:
			{
				char* errmsg = NULL;
				char** pres;
				int row=0, column=0;
				char mean[20]="";
				char word[20]="";
				ssize_t res;
				strcpy(word, buf+1);
				printf("%s\n", buf+1);
				bzero(buf, sizeof(buf));

				//查找单词是否存在,组查询语句
				sprintf(buf, "select* from dict where word=\"%s\";", word);
				if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
				{
					fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
					return NULL;
				}
				//单词存在
				if(row>0)
				{
					bzero(buf, sizeof(buf));
					//告诉客户端单词存在
					sprintf(buf, "%c%c", YES, 0);
					if(send(newfd, buf, 2, 0)<0)
					{
						perror("send");
						return NULL;
					}
					//等待接收客户端信息是否可以继续发送
					bzero(buf, sizeof(buf));
					res = recv(newfd, buf, sizeof(buf), 0);
					if(res < 0)
					{
						perror("recv");
						return NULL;
					}
					else if(res == 0)
					{
						printf("客户端下线\n");
						//需要更新用户登录状态
						update_user(db, username);

						return NULL;
					}
					//提取单词和意思
					int i;
					bzero(buf, sizeof(buf));
					//去除第一行字段
					for(i=column; i<(row+1)*column; i++)
					{

						if(i % column ==0)
						{
							strcpy(word, pres[i]);
						}
						if(i % column == (column -1))
						{
							strcpy(mean, pres[i]);

							//整合一个数组
							sprintf(buf, "%s%c%s", word, 0, mean);
							if(send(newfd, buf, strlen(word)+1+strlen(mean)+1, 0)<0)
							{
								perror("send");
								return NULL;
							}
							//获取时间
							bzero(buf, sizeof(buf));
							time_t t;
							struct tm* info = NULL;
							char time_record[20]="";
							t = time(NULL);
							info = localtime(&t);
							//整合时间数组
							sprintf(time_record, "%d-%d-%d  %d:%d", info->tm_year+1900, info->tm_mon+1, \
									info->tm_mday, info->tm_hour, info->tm_min);
							//整合插入历史记录语句
							sprintf(buf, "insert into record values(\"%s\", \"%s\", \"%s\", \"%s\");", \
									username, word, mean, time_record);
							char* errmsg = NULL;
							if(sqlite3_exec(db, buf, NULL, NULL, &errmsg) != SQLITE_OK)
							{
								fprintf(stderr, "__%d__sqlite3_ex: %s\n", __LINE__, errmsg);
								return NULL;
							}
							printf("%s历史记录插入成功\n", username);
							bzero(buf, sizeof(buf));

							res = recv(newfd, buf, sizeof(buf), 0);

							if(res<0)
							{
								perror("send");
								return NULL;
							}
							if(res == 0)
							{
								printf("客户端下线\n");
								//更新用户状态信息
								update_user(db, username);
							}
							char c;
						    c = *buf;
							if(c == YES)
							{
								//说明可以继续发送
								bzero(buf, sizeof(buf));
							}
							else if(c == NO)
							{
								//不在进行传输
								printf("停止传输\n");
								break;
							}
						}
					}
					printf("传输完成\n");
					//向客户端发送no说明传输完成
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", NO, 0);
					if(send(newfd, buf, 2, 0)<0)
					{
						perror("send");
						return NULL;
					}

				}
				else
				{
					printf("单词不存在\n");
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", NO, 0);
					if(send(newfd, buf, 2, 0)<0)
					{
						perror("send");
						return NULL;
					}
				}
				sqlite3_free_table(pres);
				pres = NULL;
			}
			break;
		case HISTORY:
			{
				printf("__%d__\n",__LINE__);
				char* errmsg = NULL;
				char** pres;
				int row=0, column=0;
				char mean[20]="";
				char word[20]="";
				char time[20]="";

				ssize_t res;
				strcpy(word, buf+1);
				printf("%s\n", buf+1);
				bzero(buf, sizeof(buf));

				//查找历史用户是否存在,组查询语句
				sprintf(buf, "select* from record where username=\"%s\";", username);
				if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
				{
					fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
					return NULL;
				}

				//如果存在历史记录
				if(row>0)
				{
					//向客户端发送yes说明有记录,打算发送数据了
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", YES, 0);
					if(send(newfd, buf, 2, 0)<0)
					{
						ERR_MSG("send");
						return NULL ;
					}
					//等待接收客户端消息
					bzero(buf, sizeof(buf));
					res = recv(newfd, buf, sizeof(buf), 0);
					if(res <0)
					{
						ERR_MSG("recv");
						return NULL;
					}
					else if(res == 0)
					{
						printf("客户端下线\n");
						//需要将登录状态值改为NOTLOGIN;
						update_user(db, username);
						break;
					}
					//拆解buf信息  默认一定为yes

					//提取查询到的历史记录信息
					int i;
					//忽略表头
					bzero(buf, sizeof(buf));
					for(i=column; i<(row+1)*column; i++)
					{
						if(i%column==1)
						{
							strcpy(word, pres[i]);
						}
						else if(i%column==2)
						{
							strcpy(mean, pres[i]);
						}
						else if(i%column==3)
						{
							strcpy(time, pres[i]);
							//整合到一个数组里
							sprintf(buf, "%s%c%s%c%s", word, 0, mean, 0, time);
							if(send(newfd, buf, strlen(word)+1+strlen(mean)+1+strlen(time), 0)<0)
							{
								ERR_MSG("send");
								return NULL;
							}

							//发送一个等待回应是否可以继续发送
							bzero(buf, sizeof(buf));
							res = recv(newfd, buf, sizeof(buf, 0), 0);
							if(res < 0)
							{
								ERR_MSG("recv");
								return NULL;
							}
							else if(res == 0)
							{
								printf("客户端下线\n");
								//更新用户状态信息
								update_user(db, username);
								break;
							}
							//判断buf信息
							if(*buf == YES)
							{
								//说明可以继续发送
							}
							else if(*buf == NO)
							{
								//不让再发送
								break;
							}
						}
					}
					printf("数据发送完毕\n");
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", NO, 0);
					//向客户发送no 说明发送完毕
					if(send(newfd, buf,2,0)<0)
					{
						ERR_MSG("send");
						return NULL;
					}
				}
				//没有历史记录
				else
				{
					bzero(buf, sizeof(buf));
					sprintf(buf, "%c%c", NO, 0);
					//向客户发送no 说明没有历史记录
					if(send(newfd, buf,2,0)<0)
					{
						ERR_MSG("send");
						return NULL;
					}
				}
				sqlite3_free_table(pres);
				pres=NULL;
			}
			break;
		case NOTLOGIN:
			{
				update_user(db, username);
			}
			break;
		default:
			printf("未知信息\n");
		}
	}
}

sqlite3* create()
{
	char sql[128]="";
	sqlite3* db = NULL;
	if(sqlite3_open("./stu.db", &db)!=SQLITE_OK)
	{
		fprintf(stderr, "__%d__sqlite3_open: %s\n",__LINE__, sqlite3_errmsg(db));
		fprintf(stderr, "error_code:%d", sqlite3_errcode(db));
		return NULL;
	}
	//单词表
	printf("sqlite3 open success\n");
	strcpy(sql,"create table if not exists dict( word char, mean char);");
	char* errmsg = NULL;
	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK)
	{
		fprintf(stderr, "__%d__sqlite3_exec: %s\n", __LINE__, errmsg);
		return NULL;
	}
	printf("create table dict success\n");
	//历史记录表
	bzero(sql, sizeof(sql));
	strcpy(sql,"create table if not exists record( username char, word char, mean char, time char);");

	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK)
	{
		fprintf(stderr, "__%d__sqlite3_exec: %s\n", __LINE__, errmsg);
		return NULL;
	}
	printf("create table record success\n");

	//用户表
	bzero(sql, sizeof(sql));
	strcpy(sql,"create table if not exists user( username char primary key, password char, stat cahr);");

	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK)
	{
		fprintf(stderr, "__%d__sqlite3_exec: %s\n", __LINE__, errmsg);
		return NULL;
	}
	printf("create table user success\n");

	//插入单词表
	printf("下载文件中...");
	do_insert(db);

	return db;
}

int do_insert(sqlite3* db)
{
	FILE *fp =fopen("./dict.txt", "r");
	char buf[50]="";
	int i=0;
	char world[15]="";
	char mean[20]="";
	int len=1;
	char sql[128]="";
	while(1)
	{
		//循环读取文件
		bzero(buf, sizeof(buf));
		if(fgets(buf, sizeof(buf), fp)==NULL)
		{
			break;
		}
		buf[strlen(buf)-1]=0;

		char* p = buf;
		//遍历判断单词和意思的位置
		for(i=0; i<strlen(buf); i++)
		{
			if(*(p+i)==' ' && *(p+i+1)==' ' && *(p+i+2)==' ')
			{
				*(p+i) = '\0';
				strcpy(world, p);
				strcpy(mean, p+i+2);

				sprintf(sql, "insert into dict values( \"%s\", \"%s\");", world, mean);

				char* errmsg = NULL;
				if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK)
				{
					fprintf(stderr, "__%d__sqlite3_exec: %s\n", __LINE__, errmsg);
					return -1;
				}
				len++;
			}

         }
	}
	printf("单词表插入成功\n");
	return 0;
 }
void update_user(sqlite3* db, char* username)
{
	char* errmsg = NULL;
	char** pres;
	int row=0, column=0;
	char buf[128]="";

	ssize_t res;
	//	strcpy(word, buf+1);
	//	printf("%s\n", buf+1);
	bzero(buf, sizeof(buf));

	//查找历史用户是否存在,组查询语句
	sprintf(buf, "select* from user where username=\"%s\"and stat=%d;", username, LOGIN);
	if(sqlite3_get_table(db, buf,&pres, &row, &column, &errmsg) != SQLITE_OK)
	{
		fprintf(stderr, "__%d__sqlite3_get_table: %s\n", __LINE__, errmsg);
		return ;
	}
	//存在已经登录的账号信息
	if(row >  0)
	{
		bzero(buf, sizeof(buf));
		//修改登录状态值
		sprintf(buf, "update user set stat=%d where username=\"%s\";", NOTLOGIN, username);
		if(sqlite3_exec(db, buf, NULL, NULL, &errmsg) != SQLITE_OK)

		{
			fprintf(stderr, "__%d__sqlite3_ex: %s\n", __LINE__, errmsg);
			return ;
		}
		printf("用户: %s已下线\n", username);

	}
	else
	{
		printf("无用户上线\n");
	}
	
}

客户端:

#include<myhead.h>
#define ERR_MSG(msg) do{\
	fprintf(stderr,"__%d__",__LINE__);\
	perror(msg);\
}while(0);

#define IP "192.168.125.58"
#define  NOTLOGIN 0
#define  LOGIN    1
#define  YES      2
#define  NO       3
#define  REGISTER 4
#define  WORD     5
#define  HISTORY  6

int search_history(int sfd);//查找历史记录
int to_register(int sfd); 	//注册
int to_login(int sfd); 		//登录
int search_word(int sfd);   //查找单词 

int main(int argc, const char *argv[])
{
	int sfd = socket(AF_INET,SOCK_STREAM,0);//创建流式套接字
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}

	//填充服务器的端口ip
	struct sockaddr_in sin;
	sin.sin_family 		=AF_INET;
	sin.sin_port 		=htons(8888);
	sin.sin_addr.s_addr =inet_addr(IP);

	//connect
	if(connect(sfd,(struct sockaddr*)&sin, sizeof(sin))<0)
	{
		ERR_MSG("connect");
		return -1;
	}
	printf("connect success\n");

	char num;
	while(1)
	{
		printf("**********************");
		printf("********1.注册********");
		printf("********2.登录********");
		printf("********3.退出********");
		printf("**********************");
		
		printf("请输入您的选择:");
		scanf("%c",&num);
		while(getchar()!=10);
		switch(num)
		{
		case '1':
			//注册
		//	to_register(sfd);
			break;
		case '2':
			//登录
		//	to_login(sfd);
			break;
		case '3':
			//退出	

			goto END;
			break;
		default:
			printf("输入错误,请从新输入\n");
		}
	}

END:
	close(sfd);

	return 0;
}

//注册
int to_register(int sfd)
{
	char c;
	char buf[128]="";
	ssize_t res;

	char username[30]="";
	char password[20]="";
	printf("请输入用户名:");
	fgets(username,sizeof(username),stdin); //从终端获取用户名
	username[strlen(username)-1] = 0;

	printf("请输入密码:");
	fgets(password,sizeof(password),stdin); //从终端获取密码
	password[strlen(password)-1] = 0;

	//组注册协议
	sprintf(buf, "%c%s%c%s", REGISTER, username, 0, password);
	
	if(send(sfd, buf, strlen(username)+strlen(password)+2, 0)<0)
	{
		ERR_MSG("send");
		return -1;
	}

	//接收服务器返回的消息
	bzero(buf,sizeof(buf));
	res = recv(sfd,buf,sizeof(buf),0);
	if(res<0)
	{
		perror("recv");
		return -1;
	}else if(res == 0)
	{
		printf("服务器关闭\n");
		return -1;
	}
	//拆解buf
	c = *buf;
	if(c == YES)
	{
		printf("注册成功\n");
	}else if(c == NO)
	{
		printf("用户已存在\n");
	}
	return 0;
}

//登录
int to_login(int sfd)
{
	ssize_t res;
	char buf[128] = "";
	char username[30] = "";
	char password[20] = "";
	bzero(username, sizeof(username));
	bzero(password, sizeof(password));
	while(1)
	{
		printf("请输入用户名:");
		fgets(username,sizeof(username),stdin);
		username[strlen(username)-1] = 0;

		printf("请输入密码:");
		fgets(password, sizeof(password),stdin);
		password[strlen(password)-1] = 0;

		bzero(buf, sizeof(buf));
		//组登录协议语句
		sprintf(buf,"%c%s%c%s",LOGIN ,username ,0 ,password);

		//向服务器发送协议
		if(send(sfd, buf, strlen(username)+strlen(password)+2,0)<0)
		{
			perror("send");
			return -1;
		}

		//等待服务器
		bzero(buf,sizeof(buf));
		res = recv(sfd, buf, sizeof(buf), 0);
		if(res<0)
		{
			perror("recv");
			return -1;
		}else if(res == 0)
		{
			printf("服务器下线\n");
			return -1;
		}

		//分解buf
		char c = *buf;
		if(c == YES)
		{
			printf("登录成功\n");
			char num;

			while(1)
			{
				printf("登录成功\n");
				printf("***********************");
				printf("******1.查询单词*******");
				printf("******2.历史记录*******");
				printf("******3.返回上级*******");
				printf("***********************");
				printf("请选择:");
				num = getchar();
				while(getchar()!=10);
				switch(num)
				{
				case '1':
					//查单词
					search_word(sfd);
					break;
				case '2':
					//查询历史记录
					search_history(sfd);
					break;
				case '3':
					//退出
					bzero(buf, sizeof(buf));
					sprintf(buf,"%c%s%c",NOTLOGIN,username,0);
					if(send(sfd,buf,strlen(username)+2,0))
					{
						perror("send");
						return -1;
					}
					return 0;
				default:
					printf("输入错误,请重新输入\n");
				}
				
			}
		}
		else if(c==NO)
		{
			printf("账号密码错误\n");
		}else if(c == LOGIN)
		{
			printf("重复登录\n");
		}
	}
	return 0;
}

//查找单词
int search_word(int sfd)
{
	char buf[128]="";
	char word[20]="";
	ssize_t res;
	//循环查找单词
	while(1)
	{
		printf("请输入要查找的单词(quit退出):");
		fgets(word, sizeof(word), stdin);
		word[strlen(word)-1]=0;

		if(strcmp(word, "quit")==0)
		{
			return -1;
		}
		//发送word协议查找单词
 
		sprintf(buf, "%c%s%c", WORD,word , 0);
		if(send(sfd, buf, 1+strlen(word)+1, 0)<0)
		{
			perror("send");
			return -1;
		}
		printf("%s\n", word);
		//等待服务器回应是否存在单词
		bzero(buf, sizeof(buf));
		res = recv(sfd, buf, sizeof(buf), 0);
		if(res < 0)
		{
			perror("recv");
			return -1;
		}
		else if(res == 0)
		{
			printf("服务器下线\n");
		}
		//拆解buf信息
		char c;
		c = *buf;
		//存在单词
		if(c == YES)
		{
			while(1)
			{
				//告诉服务器可以继续发送
				bzero(buf, sizeof(buf));
				sprintf(buf, "%c%c", YES, 0);
				if(send(sfd, buf, 2, 0)<0)
				{
					perror("send");
					return -1;
				}

				//等待服务器回应单词内容
				bzero(buf, sizeof(buf));
				res = recv(sfd, buf, sizeof(buf), 0);
				if(res < 0)
				{
					perror("recv");
					return -1;
				}
				if(res ==0)
				{
					printf("服务器下线\n");
				}

				char p = *buf;
				if(p == NO)
				{
					break; 		//传输完成
				}
				//提取单词意思
				char* mean = buf+strlen(buf)+1;
				printf("%-10s\t%s\n", buf, mean);
			}
		}
		else if(c == NO)
		{
			printf("没有这个单词\n");
		}
	}
	return 0;
}

//查询历史记录
int search_history(int sfd)
{
	char buf[128]="";
	ssize_t res;
	sprintf(buf, "%c%c", HISTORY, 0);
	if(send(sfd, buf, 2, 0)<0)
	{
		perror("send");
		return -1;
	}
	//等待服务器回应
	bzero(buf, sizeof(buf));
	res = recv(sfd, buf, sizeof(buf), 0);
	if(res<0)
	{
		perror("recv");
		return -1;
	}
	else if(res == 0)
	{
		printf("服务器下线\n");
		return -1;		
	}
	
	 //拆解buf信息
	 char c;
	 c = *buf;
	 if(c == YES)
	 {
		 while(1)
		 {
 
			 bzero(buf, sizeof(buf));
			 sprintf(buf, "%c%c", YES, 0);
			 //向服务器发送yes说明可以开始传输数据了
			 if(send(sfd, buf, 2, 0)<0)
			 {
				 perror("send");
				 return -1;
			 }
			 //等待服务器回应单词内容
			 bzero(buf, sizeof(buf));
			 res = recv(sfd, buf, sizeof(buf), 0);
			 if(res < 0)
			 {
				 perror("recv");
				 return -1;
			 }
			 if(res ==0)
			 {
				 printf("服务器下线\n");
			 }
			 char p = *buf;
			 if(p == NO)
			 {
				 //说明传输完成
				 break;
			 }
			 //提取单词意思和时间
			 char* mean = buf+strlen(buf)+1;
			 char* time = mean + strlen(mean)+1;
 
 
			 printf("%-10s\t%-20s\t%s\n", buf, mean, time);
		 }
	 }
	 //没有历史记录
	 else if(c == NO)
	 {
		 printf("没有历史记录\n");
	 }
	 printf("****over*****\n");
 
	 return 0;
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/52143.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【iOS】KVOKVC原理

1 KVO 键值监听 1.1 KVO简介 KVO的全称是Key-Value Observing&#xff0c;俗称"键值监听"&#xff0c;可以用于监听摸个对象属性值得改变。 KVO一般通过以下三个步骤使用&#xff1a; // 1. 添加监听 [self.student1 addObserver:self forKeyPath:"age"…

【C++继承】

目录 一、继承的概念及定义1.1继承的概念1.2继承的定义1.2.1定义格式1.2.2继承方式与访问限定符的组合 二、基类和派生类对象赋值转换三、继承中的作用域四、派生类的默认成员函数五、继承与友元六、继承与静态成员七、复杂的菱形继承及菱形虚拟继承八、虚拟继承的原理 一、继承…

【C++进阶之路】多态篇

文章目录 前言一、概念1.分类2.实现条件①重写虚函数1.1总结三重1.2 final与override ②父类的指针或者引用2.1普通调用VS多态调用 3.抽象类3.1. 纯虚函数3.2. 接口继承和实现继承 二、原理及使用1.虚函数表 —— 虚表2.默认成员函数2.1构造函数2.2析构函数 3. 多继承3.1普通的…

用Ubuntu交叉编译Linux内核源码并部署到树莓派4B上

参考文章 1. 配置交叉编译环境 之前在ubuntu上配置过了&#xff0c;直接跳过 2.获取Linux内核源码 Linux内核源码链接 到链接里面选择自己合适版本的内核源码下载下来&#xff0c;然后传到ubuntu中进行解压 3.Linux内核源码的配置 参考文章 厂家配linux内核源码&#xff…

深入理解Gradle构建系统的工作原理

&#x1f337;&#x1f341; 博主猫头虎 带您 Go to New World.✨&#x1f341; &#x1f984; 博客首页——猫头虎的博客&#x1f390; &#x1f433;《面试题大全专栏》 文章图文并茂&#x1f995;生动形象&#x1f996;简单易学&#xff01;欢迎大家来踩踩~&#x1f33a; &a…

使用贝叶斯滤波器通过运动模型和嘈杂的墙壁传感器定位机器人研究(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

【C++】多态的实现及其底层原理

个人主页&#xff1a;&#x1f35d;在肯德基吃麻辣烫 我的gitee&#xff1a;gitee仓库 分享一句喜欢的话&#xff1a;热烈的火焰&#xff0c;冰封在最沉默的火山深处。 文章目录 前言一、什么是多态&#xff1f;二、多态的构成条件2.1什么是虚函数&#xff1f;2.2虚函数的重写2…

ICASSP 2023 | Cough Detection Using Millimeter-Wave FMCW Radar

原文链接&#xff1a;https://mp.weixin.qq.com/s?__bizMzg4MjgxMjgyMg&mid2247486540&idx1&sn6ebd9f58e9f08a369904f9c48e12d136&chksmcf51beb5f82637a3c65cf6fa53e8aa136021e35f63a58fdd7154fc486a285ecde8b8521fa499#rd ICASSP 2023 | Cough Detection Usi…

Qt中postevent造成内存泄漏问题的通用解决方案

在Qt中由QCoreApplication统一管理Qt事件的收发和销毁,其中sendEvent为阻塞式发送,用于单线程的事件发送;postevent为非阻塞式发送,构造事件的线程和接受事件的线程可以为两个线程。 最近在做一个个人项目ShaderLab 需要绘制OpenGL实时渲染的图像,由于OpenGL渲染基本都放…

论文笔记——Influence Maximization in Undirected Networks

Influence Maximization in Undirected Networks ContributionMotivationPreliminariesNotations Main resultsReduction to Balanced Optimal InstancesProving Theorem 3.1 for Balanced Optimal Instances Contribution 好久没发paper笔记了&#xff0c;这篇比较偏理论&…

python+django+mysql项目实践一(环境准备)

python项目实践 环境说明: Pycharm 开发环境 Django 前端 MySQL 数据库 Navicat 数据库管理 创建Pycharm项目 安装Django 在pycharm文件—设置进行安装 新建Django项目 注意项目创建目录 项目默认目录文件说明: __init__.py asgi.py 【异步接受网络…

深度学习实践——模型推理优化练习

系列实验 深度学习实践——卷积神经网络实践&#xff1a;裂缝识别 深度学习实践——循环神经网络实践 深度学习实践——模型部署优化实践 深度学习实践——模型推理优化练习 深度学习实践——模型推理优化练习 模型推理优化练习架构设计练习知识蒸馏练习模型剪枝练习参数量化练…

如何高效实现文件传输:小文件采用零拷贝、大文件采用异步io+直接io

一般会如何实现文件传输&#xff1f; 服务器提供文件传输功能&#xff0c;需要将磁盘上的文件读取出来&#xff0c;通过网络协议发送到客户端。如果需要你自己编码实现这个文件传输功能&#xff0c;你会怎么实现呢&#xff1f; 通常&#xff0c;你会选择最直接的方法&#xf…

QT基于TCP协议实现数据传输以及波形绘制——安卓APP及Windows程序双版本

文章代码有非常非常之详细的解析&#xff01;&#xff01;&#xff01;诸位可放心食用 这个玩意我做了两个&#xff0c;一个是安卓app&#xff0c;一个是Windows程序。代码并非全部都是由我从无到有实现&#xff0c;只是实现了我想要的功能。多亏了巨人的肩膀&#xff0c;开源…

小研究 - 一种复杂微服务系统异常行为分析与定位算法(一)

针对极端学生化偏差&#xff08;&#xff25;&#xff58;&#xff54;&#xff52;&#xff45;&#xff4d;&#xff45; &#xff33;&#xff54;&#xff55;&#xff44;&#xff45;&#xff4e;&#xff54;&#xff49;&#xff5a;&#xff45;&#xff44; &#…

Java中的生产者/消费者模型

一、什么是生产者/消费者模型 生产者-消费者模型&#xff08;Producer-Consumer problem&#xff09;是一个非常经典的多线程并发协作的模型。 比如某个模块负责生产数据&#xff0c;而另一个模块负责处理数据。产生数据的模块就形象地被称为生产者&#xff1b;而处理数据的模…

后端一次返回大量数据,前端做分页处理

问题描述&#xff1a;后端接口返回大量数据&#xff0c;没有做分页处理&#xff0c;不支持传参pageNum&#xff0c;pageSize 本文为转载文章&#xff0c;原文章&#xff1a;后端一次返回大量数据&#xff0c;前端做分页处理 1.template中 分页 <el-paginationsize-chang…

39.手机导航

手机导航 html部分 <div class"phone"><div class"content"><img class"active" src"./static/20180529205331_yhGyf.jpeg" alt"" srcset""><img src"./static/20190214214253_hsjqw…

DHCP部署与安全详解

文章目录 一、DHCP是什么&#xff1f;二、DHCP相关概念三、DHCP优点四、DHCP原理1. 客户机发送DHCP Discovery广播包&#xff08;发现谁是DHCP服务器&#xff09;2. 服务器响应DHCP Offer广播包3. 客户机发送DHCP Request广播包4. 服务器发送DHCP ACK广播包 五、DHCP续约六、部…

ElasticSearch基本使用--ElasticSearch文章一

文章目录 官网学习必要性elasticsearch/kibana安装版本数据结构说明7.x版本说明ElasticSearch kibana工具测试后续我们会一起分析 官网 https://www.elastic.co/cn/ 学习必要性 1、在当前软件行业中&#xff0c;搜索是一个软件系统或平台的基本功能&#xff0c; 学习Elastic…