• 电子词典项目

    目录

    目录

    头文件：dict.h:

    源文件：dict.c:

    服务器测试文件：serDict.c:

    客户端测试文件：cliDict.c:

    头文件：dict.h:
    1. #ifndef __DICT_H__
    2. #define __DICT_H__
    3. #include
    4. #include
    5.  
    6. #define SERIP "192.168.114.73"
    7. #define PORT 8888
    8.  
    9. #define ERR_MSG(msg) do{\
    10. 	printf("%d: ",__LINE__);\
    11. 	perror(msg);\
    12. }while(0);
    13.  
    14. /*服务器使用  */
    15. //词典数据库的初始化和导入
    16. int dict_init(sqlite3 *db);
    17.  
    18. //TCP服务器搭建函数
    19. int TCP_ser_set(struct sockaddr_in* psin);
    20.  
    21. //回收子进程函数
    22. void handler(int signum);
    23.  
    24. //子进程中的操作
    25. void child_operate(int newfd, sqlite3 *db);
    26. /*服务器使用  */
    27.  
    28. /*客户端使用  */
    29. //TCP客户端搭建函数
    30. int TCP_cli_set();
    31.  
    32. //客户端中的操作
    33. void cli_operate(int cfd);
    34.  
    35. /*客户端使用  */
    36. #endif
    源文件：dict.c:
    1. #include
    2. #include
    3. #include "dict.h"
    4.  
    5. int do_create(sqlite3 *db);
    6. int do_insert(sqlite3 *db, char * English, char *Chinese);
    7. int msg_get(FILE *fp, char*pEng, char *pChin);
    8. int do_init(sqlite3 *db);
    9. int usrname_not_reuse(sqlite3 *db, const char *usrname, const char *tablename);
    10.  
    11. int dict_init(sqlite3 *db)
    12. {
    13. 	
    14. 	//初始化数据库中词典数据表
    15. 	do_init(db);
    16. 	printf("数据库初始化成功\n");
    17.  
    18. 	//打开文件
    19. 	FILE *fp;
    20. 	char English[32] = "";
    21. 	char Chinese[64] = "";
    22. 	if(NULL == (fp=fopen("./dict.txt","r"))){
    23. 		printf("%d:",__LINE__);
    24. 		perror("fopen error");
    25. 		return -1;
    26. 	}
    27.  
    28. 	//创建表格
    29. 	do_create(db);
    30.  
    31. 	printf("词典数据导入中\n...\n");
    32. 	while(1){
    33. 		//从dict.txt中读取一行的数据
    34. 		bzero(English, sizeof(English));
    35. 		bzero(Chinese, sizeof(Chinese));
    36. 		msg_get(fp, English, Chinese);
    37. 		//将English和Chinese写入表格中
    38. 		do_insert(db, English, Chinese);
    39.  
    40. 		//printf("%s\t%s\n",English, Chinese);
    41.  
    42. 		if(feof(fp)){
    43. 			printf("导入成功\n");
    44. 			break;
    45. 		}
    46. 	}
    47.  
    48. 	
    49. 	//关闭文件
    50. 	fclose(fp);
    51. 	return 0;
    52. }
    53.  
    54. int msg_get(FILE *fp, char* pEng, char *pChin){
    55. 	char tmp = 0;
    56. 	int i = 0;
    57. 	while((tmp = fgetc(fp))!=' '){
    58. 		pEng[i] = tmp;
    59. 		i++;
    60. 		if(feof(fp)){
    61. 			return 0;
    62. 		}
    63. 	}
    64. 	i = 0;
    65. 	while(fgetc(fp)==' ');
    66. 	fseek(fp,-1,SEEK_CUR);
    67. 	while((tmp = fgetc(fp))!='\n'){
    68. 		pChin[i] = tmp;
    69. 		i++;
    70. 		if(feof(fp)){
    71. 			pChin[i-1] = 0;
    72. 			break;
    73. 		}
    74. 	}
    75. 	return 0;
    76. }
    77.  
    78. int do_create(sqlite3 *db){
    79. 	if(db == NULL){
    80. 		printf("数据库不存在\n");
    81. 		return -1;
    82. 	}
    83.  
    84. 	//创建词典数据表
    85. 	char sql[128] = "create table if not exists dict(ENGLISH char, TRANSLATION char);";
    86.  
    87. 	char *errmsg = NULL;
    88. 	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    89. 		printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    90. 		return -1;		
    91. 	}
    92.  
    93. 	//创建已注册用户数据表
    94. 	bzero(sql,sizeof(sql));
    95. 	strcpy(sql,"create table if not exists registeredUsr(id char primary key, passwd char);");
    96.  
    97. 	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    98. 		printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    99. 		return -1;		
    100. 	}
    101. 	//创建已登录用户数据表
    102. 	bzero(sql,sizeof(sql));
    103. 	strcpy(sql,"create table if not exists loadedUsr(id char primary key, passwd char);");
    104.  
    105. 	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    106. 		printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    107. 		return -1;		
    108. 	}
    109.  
    110.  
    111. 	//创建成功
    112. 	return 0;
    113. }
    114.  
    115. int do_init(sqlite3 *db){
    116. 	if(db == NULL){
    117. 		printf("数据库不存在\n");
    118. 		return -1;
    119. 	}
    120.  
    121. 	char sql[128] = "drop table dict;";
    122.  
    123. 	char *errmsg = NULL;
    124. 	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    125. 		printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    126. 		return -1;		
    127. 	}
    128.  
    129. 	//创建成功
    130. 	return 0;
    131. }
    132.  
    133. //插入表格函数
    134. int do_insert(sqlite3 *db, char * English, char *Chinese){
    135. 	if(db == NULL){
    136. 		printf("数据库不存在\n");
    137. 		return -1;
    138. 	}
    139.  
    140. 	char sql[128] = "";
    141. 	snprintf(sql, sizeof(sql),"insert into dict values(\"%s\", \"%s\");",English, Chinese);
    142.  
    143. 	char *errmsg = NULL;
    144. 	if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    145. 		printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    146. 		return -1;		
    147. 	}
    148.  
    149. 	return 0;
    150. }
    151.  
    152. //TCP服务器搭建函数
    153. int TCP_ser_set(struct sockaddr_in* psin){
    154. 	int sfd;
    155. 	if((sfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
    156. 		ERR_MSG("socket error");
    157. 		return -1;
    158. 	}
    159.  
    160. 	int optval = 1;
    161. 	//允许端口快速复用
    162. 	if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))<0){
    163. 		ERR_MSG("setsockopt error");
    164. 		return -1;
    165. 	}
    166.  
    167. 	//获取地址信息结构体
    168. 	struct sockaddr_in sin;
    169. 	sin.sin_family = AF_INET;
    170. 	sin.sin_port = htons(PORT);
    171. 	sin.sin_addr.s_addr = inet_addr(SERIP);
    172. 	* psin = sin;
    173. 	//绑定
    174. 	if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin))<0){
    175. 		ERR_MSG("bind error");
    176. 		return -1;
    177. 	}
    178.  
    179. 	//设为监听
    180. 	if(listen(sfd,128)<0){
    181. 		ERR_MSG("listen error");
    182. 		return -1;
    183. 	}
    184.  
    185. 	printf("服务器搭建成功\n");
    186. 	return sfd;
    187. }
    188.  
    189. //回收子进程函数
    190. void handler(int signum){
    191. 	while(waitpid(-1,NULL,WNOHANG)!=0);
    192. }
    193.  
    194. //子进程中的操作
    195. void child_operate(int newfd, sqlite3 *db){
    196. 	//判断传入的newfd是否合法
    197. 	if(newfd<0){
    198. 		printf("连接失败\n");
    199. 		return;
    200. 	}
    201. 	char buf[150] = " ";
    202. 	//用于读取数据包中的操作码
    203. 	unsigned short *operatorPtr = (unsigned short*)buf;
    204. 	//用于登录后记录用户名，便于读写对应用户的历史记录数据库
    205. 	char usrname[20] = " ";
    206. 	//用于读取数据包中的用户名
    207. 	char *usrnamePtr = buf + 2;
    208. 	//需要后续计算得到数据包中数据的位置
    209. 	char *dataPtr = NULL;
    210. 	//获取用户名的长度
    211. 	int usrnameLen = 0;
    212. 	//定义一个变量接收返回值
    213. 	int res = 0;
    214. 	//保存命令的数组
    215. 	char sql[128] = " ";
    216. 	while(1){
    217. 		bzero(buf,sizeof(buf));
    218. 		//接收
    219. 		if(recv(newfd, buf, sizeof(buf), 0) == -1){
    220. 			ERR_MSG("recv error");
    221. 			break;
    222. 		}
    223. 		//获取的是用户名的长度
    224. 		usrnameLen = strlen(usrnamePtr);
    225. 		//可知数据包中数据的位置为
    226. 		dataPtr = usrnamePtr + usrnameLen + 1;
    227. 		//printf("%s\n",buf);
    228. 		//send(newfd,buf,sizeof(buf),0);
    229. 		//注册
    230. 		if(1 == *operatorPtr){
    231. 			//现在,usrnamePtr指向用户名，dataPtr是数据的起头，在注册里面，数据包应该保存用户对应的密码
    232. 			//检索已注册用户数据表，看看用户名是否存在
    233. 			res = usrname_not_reuse(db, usrnamePtr, "registeredUsr");
    234.  
    235. 			if(-1 == res){
    236. 				//说明这个函数调用遇到问题
    237. 				//组一个返回包
    238. 				*operatorPtr = 7;
    239. 				strcpy(dataPtr,"there is something wrong");
    240. 			}else if(0 == res){
    241. 				//说明用户名已存在
    242. 				*operatorPtr = 7;
    243. 				strcpy(dataPtr,"用户名已存在");
    244. 			}else if(1 == res){
    245. 				//说明用户名不在数据库中，可以进行注册
    246. 				bzero(sql, sizeof(sql));
    247.  
    248. 				snprintf(sql, sizeof(sql),"insert into registeredUsr values(\"%s\", \"%s\");",usrnamePtr, dataPtr);
    249.  
    250. 				char *errmsg = NULL;
    251. 				if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    252. 					printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    253. 					break;	
    254. 				}
    255.  
    256. 				*operatorPtr = 7;
    257. 				strcpy(dataPtr,"注册成功");
    258.  
    259. 			}
    260.  
    261. 		}else if(2 == *operatorPtr){
    262. 			//登录
    263. 			//现在,usrnamePtr指向用户名，dataPtr是数据的起头，在登录里面，数据包应该保存用户对应的密码
    264. 			//检索已登录用户数据表，看看用户名是否存在
    265. 			res = usrname_not_reuse(db, usrnamePtr, "registeredUsr");
    266. 			if(-1 == res){
    267. 				//说明这个函数调用遇到问题
    268. 				//组一个返回包
    269. 				*operatorPtr = 7;
    270. 				strcpy(dataPtr,"there is something wrong");
    271. 			}else if(1 == res){
    272. 				//说明在已注册表中未找到该用户，说明该账号还没被注册
    273. 				*operatorPtr = 7;
    274. 				strcpy(dataPtr,"该账号还未被注册，请先注册");
    275. 			}else if(0 == res){
    276. 				//说明在已注册表中找到了该用户,进行下一步登录操作
    277. 				res = usrname_not_reuse(db, usrnamePtr, "loadedUsr");
    278. 				if(-1 == res){
    279. 					//说明这个函数调用遇到问题
    280. 					//组一个返回包
    281. 					*operatorPtr = 7;
    282. 					strcpy(dataPtr,"there is something wrong");
    283. 				}else if(0 == res){
    284. 					//说明用户名已存在已登录数据表，说明用户已经登录
    285. 					*operatorPtr = 7;
    286. 					strcpy(dataPtr,"该账号已登录，请检查账号是否被盗用");
    287. 				}else if(1 == res){
    288. 					//说明该用户已注册且未登录，可以进行登录
    289. 					bzero(sql, sizeof(sql));
    290.  
    291. 					char **result = NULL;
    292. 					int row = 0;
    293. 					int col = 0;
    294. 					char *errmsg = NULL;
    295. 					int flag = 0;
    296.  
    297. 					snprintf(sql,sizeof(sql),"select id,passwd from registeredUsr;");
    298.  
    299. 					if((res = sqlite3_get_table(db, sql, &result, &row, &col, &errmsg))!=0){
    300. 						printf("%d:sqlite3_get_table error\n",__LINE__);
    301. 						printf("%s\n",strerror(res));
    302. 						break;
    303. 					}
    304.  
    305. 					//遍历比较,第0行是项的名，所以从第一行开始
    306. 					for(int i=col; i<=row*col; i+=col){
    307. 						if(strcmp(*(result+i),usrnamePtr) == 0&&strcmp(*(result+i+1),dataPtr) == 0){
    308. 							//登录成功后要将用户数据写入已登录用户数据表
    309. 							bzero(sql, sizeof(sql));
    310.  
    311. 							snprintf(sql, sizeof(sql),"insert into loadedUsr values(\"%s\", \"%s\");",usrnamePtr, dataPtr);
    312.  
    313. 							char *errmsg = NULL;
    314. 							if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    315. 								printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    316. 								break;	
    317. 							}
    318. 							//满足条件说明用户密码匹配成功,即登录成功
    319. 							*operatorPtr = 7;
    320. 							strcpy(dataPtr,"登录成功");
    321. 							//将登录成功的用户名保存
    322. 							strcpy(usrname,usrnamePtr);
    323. 							flag = 0;
    324.  
    325. 							//然后应该新建一个对应用户的历史记录数据表
    326. 							bzero(sql, sizeof(sql));
    327. 							snprintf(sql, sizeof(sql),"create table if not exists %shis(ENGLISH char , TRANSLATION char, current timestamp default current_timestamp);",usrname);
    328. 							if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    329. 								printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    330. 								break;		
    331. 							}
    332.  
    333. 							break;
    334. 						}else{
    335. 							flag = 1;
    336. 						}
    337. 					}
    338.  
    339. 					if(1 == flag){
    340. 						*operatorPtr = 7;
    341. 						strcpy(dataPtr,"密码错误");
    342. 					}
    343.  
    344. 				}
    345. 			}
    346.  
    347. 		}else if(3 == *operatorPtr){
    348. 			//退出
    349. 			//先判断该进程中usrname字符串内是否有内容,如果有的话，说明用户是异常退出，先帮用户
    350. 			//退出登录，再进行退出操作
    351. 			if(usrname[0]!=0){
    352. 				//usrname字符串的第一个元素不为０，说明非空，检查usrname字符串内容是否在
    353. 				//已登录用户信息数据表中
    354. 				res = usrname_not_reuse(db, usrname, "loadedUsr");
    355. 				if(0 == res){
    356. 					//说明用户还在已登录用户信息表中，说明用户确实是异常退出，先退出登录
    357. 					//从已登录用户数据表中，将用户名对应的项删除
    358. 					bzero(sql, sizeof(sql));
    359. 					char *errmsg = NULL;
    360. 					snprintf(sql,sizeof(sql),"delete from loadedUsr where id=\'%s\';",usrname);
    361.  
    362. 					if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    363. 						printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    364. 						break;	
    365. 					}
    366. 					//将usrname这个字符串清空
    367. 					bzero(usrname,sizeof(usrname));
    368.  
    369. 				}else if(1 == res){
    370. 					//说明用户已经退出登录
    371. 					bzero(usrname,sizeof(usrname));
    372. 				}		
    373. 			}
    374.  
    375. 			//结束函数
    376. 			return;
    377.  
    378. 		}else if(4 == *operatorPtr){
    379. 			//查询
    380. 			//接收到要查询的英文单词，需要在dict数据表中查找，没找到的话也应该返回一个数据提示
    381. 			bzero(sql, sizeof(sql));
    382.  
    383. 			char **result = NULL;
    384. 			int row = 0;
    385. 			int col = 0;
    386. 			char *errmsg = NULL;
    387. 			int flag = 0;
    388.  
    389. 			snprintf(sql,sizeof(sql),"select ENGLISH,TRANSLATION from dict where ENGLISH=\'%s\';",dataPtr);
    390.  
    391. 			if((res = sqlite3_get_table(db, sql, &result, &row, &col, &errmsg))!=0){
    392. 				printf("%d:sqlite3_get_table error\n",__LINE__);
    393. 				printf("%s\n",strerror(res));
    394. 				break;
    395. 			}
    396.  
    397. 			*operatorPtr = 7;
    398. 			if(strcmp(*(result+2),dataPtr)==0){
    399. 				//如果查找到的因为原型与发送来的相同，说明要找的单词存在
    400. 				snprintf(dataPtr,128,"%s\t%s",*(result+2),*(result+3));
    401.  
    402. 				//将对应的英文及其翻译还有当时时间记录
    403. 				bzero(sql, sizeof(sql));
    404.  
    405. 				snprintf(sql, sizeof(sql),"insert into %shis values(\"%s\", \"%s\",CURRENT_TIMESTAMP);",usrname, *(result+2), *(result+3));
    406.  
    407. 				if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    408. 					printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    409. 					break;	
    410. 				}
    411.  
    412. 			}else{
    413. 				//否则不存在，发送一个反馈的包
    414. 				strcpy(dataPtr,"抱歉该单词还未收录");
    415. 			}
    416. 			
    417.  
    418. 		}else if(5 == *operatorPtr){
    419. 			//历史记录
    420. 			bzero(sql, sizeof(sql));
    421.  
    422. 			char **result = NULL;
    423. 			int row = 0;
    424. 			int col = 0;
    425. 			char *errmsg = NULL;
    426. 			int flag = 0;
    427.  
    428. 			bzero(sql, sizeof(sql));
    429.  
    430. 			snprintf(sql,sizeof(sql),"select * from %shis;",usrname);
    431. 			//printf("%s\n",sql);
    432.  
    433. 			if((res = sqlite3_get_table(db, sql, &result, &row, &col, &errmsg))!=0){
    434. 				printf("%d:sqlite3_get_table error\n",__LINE__);
    435. 				printf("%s\n",strerror(res));
    436. 				break;
    437. 			}
    438.  
    439. 			*operatorPtr = 7;
    440. 			for(int i=col; i<=row*col; i+=col){
    441. 				*operatorPtr = 7;
    442. 				snprintf(dataPtr,128,"%s\t%s\t%s",*(result+i),*(result+i+1),*(result+i+2));
    443. 				//发送返回的数据包
    444. 				send(newfd, buf, sizeof(buf), 0);
    445. 				bzero(dataPtr,128);
    446. 			}
    447. 		}else if(6 == *operatorPtr){
    448. 			//退出登录
    449. 			//从已登录用户数据表中，将用户名对应的项删除
    450. 			bzero(sql, sizeof(sql));
    451. 			char *errmsg = NULL;
    452. 			snprintf(sql,sizeof(sql),"delete from loadedUsr where id=\'%s\';",usrname);
    453.  
    454. 			if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) != SQLITE_OK){
    455. 				printf("%d:sqlite3_exec error %s\n",__LINE__, sqlite3_errmsg(db));
    456. 				break;	
    457. 			}
    458. 			//将usrname这个字符串清空
    459. 			bzero(usrname,sizeof(usrname));
    460. 			*operatorPtr = 7;
    461. 			strcpy(dataPtr,"账号成功退出登录");
    462. 		}else{
    463. 		}
    464. 		//发送返回的数据包
    465. 		send(newfd, buf, sizeof(buf), 0);
    466. 	}
    467.  
    468. }
    469.  
    470. //查询用户名是否重复函数
    471. int usrname_not_reuse(sqlite3 *db, const char *usrname, const char *tablename){
    472. 	char **res = NULL;
    473. 	int row = 0;
    474. 	int col = 0;
    475. 	char *errmsg = NULL;
    476.  
    477. 	//调用查询函数
    478. 	char sql[128] = " ";
    479. 	snprintf(sql,sizeof(sql),"select id from %s;",tablename);
    480.  
    481. 	if(sqlite3_get_table(db, sql, &res, &row, &col, &errmsg)!=0){
    482. 		printf("%d:sqlite3_get_table error\n",__LINE__);
    483. 		return -1;
    484. 	}
    485. 	
    486. 	//遍历比较,第0行是项的名，所以从１开始
    487. 	for(int i=1; i<=row; i++){
    488. 		if(strcmp(*(res+i),usrname) == 0){
    489. 			//满足条件说明用户名已存在,返回0
    490. 			return 0;
    491. 		}
    492. 	}
    493.  
    494. 	//遍历到结束，说明该用户名还未存在,返回1
    495. 	return 1;
    496. }
    497.  
    498. //TCP客户端搭建函数
    499. int TCP_cli_set(){
    500. 	int cfd;
    501. 	if((cfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
    502. 		ERR_MSG("socket error");
    503. 		return -1;
    504. 	}
    505.  
    506. 	int optval = 1;
    507. 	//允许端口快速复用
    508. 	if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))<0){
    509. 		ERR_MSG("setsockopt error");
    510. 		return -1;
    511. 	}
    512.  
    513. 	//获取地址信息结构体
    514. 	struct sockaddr_in sin;
    515. 	sin.sin_family = AF_INET;
    516. 	sin.sin_port = htons(PORT);
    517. 	sin.sin_addr.s_addr = inet_addr(SERIP);
    518.  
    519. 	//连接
    520. 	if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin))<0){
    521. 		ERR_MSG("connect error");
    522. 		return -1;
    523. 	}
    524.  
    525. 	printf("客户端搭建成功\n");
    526. 	return cfd;
    527. }
    528.  
    529. //客户端中的操作
    530. void cli_operate(int cfd){
    531. 	if(cfd<0){
    532. 		printf("文件描述符有误\n");
    533. 		return;
    534. 	}
    535. 	//菜单
    536. 	int opt = 0;
    537. 	char buf[150] = " ";
    538. 	unsigned short *operatorPtr = (unsigned short *)buf;
    539. 	//记录用户名
    540. 	char id[20] = " ";
    541. 	//记录用户名长度
    542. 	int idlen = 0;
    543. 	//记录已登录用户的用户名
    544. 	char loadedid[20] = " ";
    545. 	int loadedidlen = 0;
    546. 	//记录密码
    547. 	char passwd[20] = " ";
    548. 	//记录密码长度
    549. 	int passwdlen = 0;
    550. 	while(1){
    551. 		bzero(buf,sizeof(buf));
    552. 		bzero(id,sizeof(id));
    553. 		bzero(passwd,sizeof(passwd));
    554.  
    555. 		system("clear");
    556. 		printf("****************************\n");
    557. 		printf("**********电子词典**********\n");
    558. 		printf("***********1.注册***********\n");
    559. 		printf("***********2.登录***********\n");
    560. 		printf("***********3.退出***********\n");
    561. 		printf("****************************\n");
    562. 		printf("请输入>>");
    563. 		scanf("%d",&opt);
    564.  
    565. 		if(1 == opt){
    566. 			//注册
    567. 			*operatorPtr = 1;
    568. 			printf("请输入要注册的用户名:");
    569. 			while(1){
    570. 				scanf("%s",id);
    571. 				while(getchar()!=10);
    572. 				//记录账号长度，保证长度符合要求才能跳出循环
    573. 				idlen = strlen(id);
    574. 				if(idlen>0&&idlen<20){
    575. 					break;
    576. 				}
    577. 				printf("账号长度请不要超过20,请重新输入:");
    578. 			}
    579. 			printf("请输入密码:");
    580. 			while(1){
    581. 				scanf("%s",passwd);
    582. 				while(getchar()!=10);
    583. 				//记录密码长度，保证长度符合要求才能跳出循环
    584. 				passwdlen = strlen(passwd);
    585. 				if(passwdlen<20&&passwdlen>0){
    586. 					break;
    587. 				}
    588. 				printf("密码长度请不要超过20,请重新输入:");
    589. 			}
    590. 			//将账号写到对应位置
    591. 			strcpy(buf+2,id);
    592. 			//将密码写到对应位置
    593. 			strcpy(buf+3+idlen,passwd);
    594.  
    595. 			send(cfd, buf, sizeof(buf), 0);
    596. 			recv(cfd, buf, sizeof(buf), 0);
    597. 			printf("%s\n",buf+3+idlen);
    598.  
    599. 		}else if(2 == opt){
    600. 			//登录
    601. 			*operatorPtr = 2;
    602. 			printf("请输入要登录的用户名:");
    603. 			while(1){
    604. 				scanf("%s",id);
    605. 				while(getchar()!=10);
    606. 				//记录账号长度，保证长度符合要求才能跳出循环
    607. 				idlen = strlen(id);
    608. 				if(idlen>0&&idlen<20){
    609. 					break;
    610. 				}
    611. 				printf("账号长度请不要超过20,请重新输入:");
    612. 			}
    613. 			printf("请输入密码:");
    614. 			while(1){
    615. 				scanf("%s",passwd);
    616. 				while(getchar()!=10);
    617. 				//记录密码长度，保证长度符合要求才能跳出循环
    618. 				passwdlen = strlen(passwd);
    619. 				if(passwdlen<20&&passwdlen>0){
    620. 					break;
    621. 				}
    622. 				printf("密码长度请不要超过20,请重新输入:");
    623. 			}
    624. 			//将账号写到对应位置
    625. 			strcpy(buf+2,id);
    626. 			//将密码写到对应位置
    627. 			strcpy(buf+3+idlen,passwd);
    628.  
    629. 			send(cfd, buf, sizeof(buf), 0);
    630. 			recv(cfd, buf, sizeof(buf), 0);
    631. 			printf("%s\n",buf+3+idlen);
    632. 			if(strcmp(buf+3+idlen,"登录成功")==0){
    633. 				strcpy(loadedid,id);
    634. 				loadedidlen = idlen;
    635. 				//将账号写到对应位置
    636. 				strcpy(buf+2,loadedid);
    637.  
    638. 				printf("输入任意字符刷新>>");
    639. 				getchar();
    640. 				while(getchar()!=10);
    641.  
    642. 				while(1){
    643. 					strcpy(buf+2,loadedid);
    644. 					system("clear");
    645. 					printf("****************************\n");
    646. 					printf("**********电子词典**********\n");
    647. 					printf("*****usr:%s*****\n",loadedid);
    648. 					printf("***********1.查询***********\n");
    649. 					printf("*********2.历史记录*********\n");
    650. 					printf("*********3.退出登录*********\n");
    651. 					printf("****************************\n");
    652. 					printf("请输入>>");
    653. 					scanf("%d",&opt);
    654.  
    655. 					if(1 == opt){
    656. 						//查找
    657. 						*operatorPtr = 4;
    658. 						printf("请输入要查找的单词>>");
    659. 						scanf("%s",buf+3+loadedidlen);
    660.  
    661. 						send(cfd, buf, sizeof(buf), 0);
    662. 						recv(cfd, buf, sizeof(buf), 0);
    663. 						printf("%s\n",buf+3+loadedidlen);
    664. 					}else if(2 == opt){
    665. 						//历史记录
    666. 						*operatorPtr = 5;
    667. 						//由于已经将用户id写入buf包中,只需将包发送即可
    668. 						send(cfd, buf, sizeof(buf), 0);
    669. 						recv(cfd, buf, sizeof(buf), 0);
    670. 						char *dataPtr = buf+3+loadedidlen;
    671. 						//应该循环接收，那么服务器发包应该在数据区写入结束标志
    672. 						while(*dataPtr){
    673. 							printf("%s\n",dataPtr);
    674. 							recv(cfd, buf, sizeof(buf), 0);
    675. 						}
    676. 					}else if(3 == opt){
    677. 						//退出登录
    678. 						//发送一个操作码为６的空包，向服务器提示该账号要退出登录
    679. 						//将记录已登录id的字符串清空，用于存储下一个登录用户id
    680. 						*operatorPtr = 6;
    681. 						send(cfd, buf, sizeof(buf), 0);
    682.  
    683. 						recv(cfd, buf, sizeof(buf), 0);
    684. 						printf("%s\n",buf+3+loadedidlen);
    685.  
    686. 						bzero(loadedid,sizeof(loadedid));
    687. 						loadedidlen = 0;
    688. 						break;
    689. 					}else{
    690. 						printf("输入不规范，亲人两行泪，请重新输入\n");
    691. 					}
    692.  
    693. 					printf("输入任意字符刷新>>");
    694. 					getchar();
    695. 					while(getchar()!=10);
    696. 					bzero(buf,sizeof(buf));
    697. 				}
    698. 			}
    699. 		}else if(3 == opt){
    700. 			//退出
    701. 			//发送一个操作码为３的空包
    702. 			*operatorPtr = 3;
    703. 			send(cfd, buf, sizeof(buf), 0);
    704. 			break;
    705. 		}else{
    706. 			printf("输入不规范，亲人两行泪，请重新输入\n");
    707. 		}
    708.  
    709. 		printf("输入任意字符刷新>>");
    710. 		getchar();
    711. 		while(getchar()!=10);
    712. 	}
    713.  
    714.  
    715.  
    716. }
    服务器测试文件：serDict.c:
    1. #include
    2. #include
    3. #include "dict.h"
    4.  
    5. int main(int argc, const char *argv[])
    6. {
    7. 	//回收子进程
    8. 	signal(SIGCHLD,handler);
    9.  
    10. 	//打开数据库
    11. 	sqlite3 * db;
    12. 	if(sqlite3_open("./dict.db", &db) != SQLITE_OK){
    13. 		printf("%d:sqlite3_open error %s\n",__LINE__, sqlite3_errmsg(db));
    14. 		return -1;
    15. 	}
    16.  
    17. 	//初始化数据库，完成词典数据表的重载以及用户信息数据库的导入
    18. 	dict_init(db);
    19.  
    20. 	struct sockaddr_in sin;
    21. 	socklen_t addrlen = sizeof(sin);
    22. 	int sfd;
    23. 	if((sfd = TCP_ser_set(&sin))<0){
    24. 		printf("服务器搭建失败");
    25. 		return -1;
    26. 	}
    27.  
    28. 	pid_t pid;
    29. 	int newfd;
    30. 	while(1){
    31. 		if((newfd = accept(sfd,  (struct sockaddr*)&sin, &addrlen))<0){
    32. 			ERR_MSG("accept error");
    33. 			return 0;
    34. 		}
    35.  
    36. 		pid = fork();
    37. 		if(pid == 0){		
    38. 			close(sfd);
    39. 		
    40. 			printf("这是子进程\n");
    41. 			child_operate(newfd, db);
    42.  
    43. 			close(newfd);
    44. 			//关闭数据库
    45. 			if(sqlite3_close(db) != SQLITE_OK){
    46. 				printf("%d:sqlite3_close error %s\n",__LINE__, sqlite3_errmsg(db));
    47. 				return -1;		
    48. 			}
    49. 			exit(EXIT_SUCCESS);
    50. 		}
    51. 		close(newfd);
    52.  
    53. 	}
    54.  
    55.  
    56. 	//关闭数据库
    57. 	if(sqlite3_close(db) != SQLITE_OK){
    58. 		printf("%d:sqlite3_close error %s\n",__LINE__, sqlite3_errmsg(db));
    59. 		return -1;		
    60. 	}
    61. 	close(sfd);
    62. 	return 0;
    63. }
    客户端测试文件：cliDict.c:
    1. #include
    2. #include
    3. #include "dict.h"
    4.  
    5. int cfd;
    6.  
    7. //用户按下ctrl+c后给服务器发一个退出登录的包
    8. void handlerINT(int signum){
    9. 	char buf[150] = " ";
    10. 	unsigned short *operatorPtr = (unsigned short*)buf;
    11. 	//发送一个操作码为3的空包，向服务器提示该账号要退出,退出功能中包含了退出登录
    12. 	*operatorPtr = 3;
    13. 	send(cfd, buf, sizeof(buf), 0);
    14. }
    15.  
    16. int main(int argc, const char *argv[])
    17. {
    18. 	//用户按下ctrl+c后给服务器发一个退出登录的包
    19. 	signal(2,handlerINT);
    20.  
    21. 	//调用TCP客户端搭建函数
    22. 	if((cfd = TCP_cli_set())<0){
    23. 		printf("客户端搭建失败\n");
    24. 	}
    25.  
    26. 	cli_operate(cfd);
    27.  
    28. 	
    29. 	close(cfd);	
    30. 	return 0;
    31. }

  • 相关阅读:
    【数据结构之栈、队列、数组】
    [CM311-1A]-查看安卓的分区存储情况
    npm install 报错 chromedriver 安装失败的解决办法
    Map和Set的详解
    【1++的数据结构】之哈希（一）
    分享图片或链接到抖音
    300万数据导入导出优化方案，从80s优化到8s（实测）
    2个器件，做1个恒流源
    详解JS遍历对象的五种方法
    Elasticsearch（macbook搭建，Elasticsearch+kibana）一步到位
  • 原文地址：https://blog.csdn.net/sy311SB/article/details/132916283