前言:

  最近在学进程间通信,所以做了一个小项目练习一下。主要用消息队列和socket(UDP)实现这个系统,并数据库存储数据,对C语言操作数据库不熟悉的可以参照我的这篇博客:https://www.cnblogs.com/liudw-0215/p/9593414.html,所有代码提交我的Github上,地址:https://github.com/ldw0215/Chat-System.git,可以自行下载,然后make一下就可以了。

   一、项目要求

  1. 要求实现用户注册、用户登录功能,密码需加密显示
  2. 要求实现聊天功能,双方能互发消息
  3. 数据要求数据库存储

  二、架构解析

  主要流程图如下:

    

  主要有客户端(用户)和服务端,客户端发送注册、登录请求,服务端回应请求,并且双方可以模拟聊天(互相发送消息),主要客户端请求界面见下图:

  

  注册、登录使用消息队列进行通信的,聊天是通过socket(UDP)实现的!数据存在数据库中,需要一张数据表,建表数据语句如下:

  

CREATE TABLE `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(64) NOT NULL DEFAULT '',
`password` varchar(64) NOT NULL DEFAULT '',
`check` varchar(64) NOT NULL DEFAULT '',
PRIMARY KEY (`id`),
UNIQUE KEY `name` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=52 DEFAULT CHARSET=utf8;

  三、客户端实现

  client.c创建不同的消息队列的键,根据不同的消息类型的进行发送,并等待服务端响应,client.c代码如下:

  

#include "my.h"

Msg m;
Msg_stoc msg_stoc; static int msgid_ctos;
static int msgid_stoc; void showmenu()
{
puts("-------CHAT----------");
puts("| 1:发送 2:接收 |");
puts("| 3:退出 |");
puts("--------------------");
} void show()
{
puts("-------CHAT----------");
puts("| 1:注册 2:登录 |");
puts("| 0:退出 |");
puts("--------------------");
} void send1()
{
printf("%s","send");
char buf[] = {'\0'};
char str[] = {'\0'};
struct sockaddr_in dui,zj;
int n;
short x;
int sockfd = socket(AF_INET,SOCK_DGRAM,);
if(sockfd < )
{
perror("socket");
exit(-); }
zj.sin_family = AF_INET;
zj.sin_port = htons();
zj.sin_addr.s_addr = htonl(INADDR_ANY);
n = bind(sockfd,(struct sockaddr *)&zj,sizeof(zj));
if(n < )
{
close(sockfd);
perror("bind");
exit(-); }
//puts("请输入对方号码 端口 IP ");
//scanf("%hd%s",&x,buf);
getchar();
dui.sin_addr.s_addr = inet_addr("10.10.3.129");
dui.sin_port = htons();
dui.sin_family = AF_INET;
puts("请输入想要发送的内容:");
//gets(str);
fgets(str,,stdin); n = sendto(sockfd,str,sizeof(str),,(struct sockaddr *)&dui,sizeof(dui));
if(n <= )
{
close(sockfd);
perror("sendto");
exit(-); }
close(sockfd);
return; }
#if 1
void asend(int sockfd,struct sockaddr_in dui)
{
char buf[] = {'\0'};
int n;
puts("请输入要回复的内容:");
fgets(buf,,stdin);
//gets(buf);
n = sendto(sockfd,buf,sizeof(buf),,(struct sockaddr*)&dui,sizeof(dui));
if(n <= )
{
perror("sendto");
close(sockfd);
exit(-); }
close(sockfd);
return ;
} void choose1(char ch ,int sockfd,struct sockaddr_in dui)
{
switch(ch)
{
case 'a':
asend(sockfd,dui);
break;
case 'n':
break;
default:
puts("input error!");
break; }
}
#endif
void recv1()
{
struct sockaddr_in dui,zj;
socklen_t len = sizeof(dui);
int n;
char buf[] = {'\0'};
char ch;
int sockfd = socket(AF_INET,SOCK_DGRAM,);
if(sockfd < )
{
perror("socket");
exit(-); }
zj.sin_family = AF_INET;
zj.sin_port = htons();
zj.sin_addr.s_addr = htonl(INADDR_ANY);
n = bind(sockfd,(struct sockaddr *)&zj,sizeof(zj));
if(n < )
{
close(sockfd);
perror("bind");
exit(-); }
n = recvfrom(sockfd,buf,sizeof(buf),,(struct sockaddr *)&dui,&len);
if(n <= )
{
close(sockfd);
perror("recvfrom");
exit(-);
}
puts(buf);
puts("是否要回复: 回复-》a,不回复-》n");
ch = getchar();
getchar();
choose1(ch,sockfd,dui);
} void choose(int ch)
{
printf("%d",ch);
switch(ch)
{
case :
m.type = ;
msgsnd(msgid_ctos,&m,sizeof(m)-sizeof(m.type),);
send1();
break;
case :
recv1();
break;
case :
exit();
break;
default:
puts("input error!");
break; }
} void regis()
{
printf("请输入姓名:");
scanf("%s",m.name); printf("请输入密码:");
scanf("%s",m.passwd);
m.type=;
} void login(void)
{
printf("请输入用户名:");
scanf("%s",&m.name); printf("请输入密码:");
scanf("%s",&m.passwd);
m.type=;
} int main(int argc ,char *argv[])
{
msgid_ctos=get_ctos_msg();
msgid_stoc=get_stoc_msg(); int temptype; while()
{
show();
int a = ;
scanf("%d",&a);
getchar();
switch(a)
{
case :return ;
case :regis();temptype=;break; //注册
case :login();temptype=;break; //登录
} int ret;
long type=; printf("name:%s,passwd:%s\n", m.name,m.passwd);
msgsnd(msgid_ctos,&m,sizeof(m)-sizeof(m.type),); sleep();
msgrcv(msgid_stoc,&msg_stoc,sizeof(msg_stoc),temptype,); if( == strcmp(msg_stoc.check,"yes"))
{
printf("%s",msg_stoc.info);
break;
}
} while()
{
showmenu();
int ch;
puts("请输入功能");
scanf("%d",&ch);
getchar();
printf("%d",ch);
choose(ch);
}
return ;
}

  注意,不同的通信,要用创建不同消息队列的键,并且消息类型也要不同!

  四、服务端实现

  服务端主要接送并响应客户端,主要创建不同的子进程,然后调用exec族函数,调用二进制文件,并通过消息队列接收阻塞执行,并建立信号,检测Ctrl+c信号,是进程退出,服务端响应截图如下:

  

  其实现代码如下:

  

#include"my.h"

static pid_t sub_pid[];

static int msgid_ctos;
static int msgid_stoc; void sigint(int signum)
{
int i;
for(i=;i<;i++)
{
kill(sub_pid[i],SIGKILL);
} } int main(int argc,char*argv[])
{
signal(SIGINT,sigint); msgid_ctos=get_ctos_msg();
msgid_stoc=get_stoc_msg(); sub_pid[]=vfork();
if(==sub_pid[])
{
execl("register","register",NULL);
} sub_pid[]=vfork();
if(==sub_pid[])
{
execl("login","login",NULL);
} sub_pid[]=vfork();
if(==sub_pid[])
{
execl("chat","chat",NULL);
} wait(NULL);
return ;
}

  四、各模块及数据库解析

  数据库是通过数据库函数实现的,需要头文件<mysql.h>,并链上动态库-I/usr/include/mysql -L/usr/lib64/mysql -lmysqlclient,数据量比较小,之后还要考虑优化的问题;

  注册、登录、聊天都是不同的.c文件生成二进制实现的:

  注册通过消息队列接收用户名和密码存入数据库,代码如下:

  

#include"my.h"

Msg per;
Msg_stoc msg_stoc; static int msgid_ctos;
static int msgid_stoc; void open_cli()
{
MYSQL conn;
int res;
//MYSQL_RES * result;
//MYSQL_ROW row;
mysql_init(&conn); //第三、四和五个参数,需要自己修改一下
if (mysql_real_connect(&conn, "localhost", "root", "p@s#0fSPV", "pvault", , NULL, )) {
printf("coneect mysql successful\n");
char insert_query[];
//insert
memset(insert_query, , sizeof(insert_query));
strcat(insert_query, "insert into user(name,password) values('");
strcat(insert_query, per.name);
strcat(insert_query, "','");
strcat(insert_query, per.passwd);
strcat(insert_query, "')");
printf("SQL语句: %s\n", insert_query);
res = mysql_query(&conn, insert_query);
if (!res) {
printf("insert %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
sprintf(msg_stoc.check,"%s","no");
}
else {
printf("insert error\n");
} }
} int main()
{
msgid_ctos = get_ctos_msg();
msgid_stoc = get_stoc_msg(); //int sockfd = socket_rcv();
while()
{
int n;
long type;
//per.type = 1;
msgrcv(msgid_ctos,&per,sizeof(per)-sizeof(type),,);
printf("name:%s,passwd:%s\n", per.name,per.passwd);
sleep();
open_cli();
//Msg m;
msg_stoc.type = ;
sprintf(msg_stoc.check,"%s","no");
printf("check:%s", msg_stoc.check);
msgsnd(msgid_stoc,&msg_stoc,sizeof(msg_stoc)-sizeof(type),);
}
}

  登录也是通过消息队列接收用户名和密码,并从查询出数据,进行对比,是否可以登录,代码如下:

  

#include"my.h"

Msg per;
Msg_stoc msg_stoc; static int msgid_ctos;
static int msgid_stoc; void login(void)
{
MYSQL conn;
int res;
MYSQL_RES * result;
MYSQL_ROW row;
mysql_init(&conn); //第三、四和五个参数,需要自己修改一下
if (mysql_real_connect(&conn, "localhost", "root", "p@s#0fSPV", "pvault", , NULL, )) {
printf("coneect mysql successful\n");
char select_query[] = {};
snprintf(select_query,,"select name,password from user where name='%s'",per.name);
printf("SQL语句: %s\n", select_query);
if (mysql_query(&conn, select_query) != ) {
fprintf(stderr, "查询失败\n");
exit();
}
else {
if ((result = mysql_store_result(&conn)) == NULL) {
fprintf(stderr, "保存结果集失败\n");
exit();
}
else {
while ((row = mysql_fetch_row(result)) != NULL) {
printf("name is %s , ", row[]);
printf("age is %s\n", row[]);
if(( == strcmp(row[],per.name)) && ( == strcmp(row[],per.passwd)))
strcpy(per.info,"login success!");
}
}
} }
} int main()
{
msgid_ctos = get_ctos_msg();
msgid_stoc = get_stoc_msg(); //int sockfd = socket_rcv();
while()
{
int n;
long type;
//per.type = 3;
msgrcv(msgid_ctos,&per,sizeof(per)-sizeof(type),,);
//printf("name:%s,passwd:%s\n", per.name,per.passwd);
sleep();
login();
//Msg m;
msg_stoc.type = ;
sprintf(msg_stoc.check,"%s","yes");
printf("check:%s", per.info);
msgsnd(msgid_stoc,&msg_stoc,sizeof(msg_stoc)-sizeof(type),);
}
}

  

  聊天是通过socket(UDP)实现的。

  总结:通过做这种小项目学到了很多,也发现许多不足,最重要的就是架构能力,之前都是做一小块,没有大局观,虽然项目小,但五张俱全,很锻炼人,继续找项目做!

  

消息队列、socket(UDP)实现简易聊天系统的更多相关文章

  1. 用消息队列和socket实现聊天系统

    前言:最近在学进程间通信,所以做了一个小项目练习一下.主要用消息队列和socket(UDP)实现这个系统,并数据库存储数据,对C语言操作不熟悉的可以参照我的这篇博客:https://www.cnblo ...

  2. 7月目标 socket , 一致性哈希算法 ; mongodb分片; 分布式消息队列; 中间件的使用场景

      分布式的基础:一致性哈希  路由算法的一致性hash http://www.jiacheo.org/blog/174 http://www.tuicool.com/articles/vQVbmai ...

  3. .NetCore利用BlockingCollection实现简易消息队列

    前言 消息队列现今的应用场景越来越大,常用的有RabbmitMQ和KafKa. 我们用BlockingCollection来实现简单的消息队列. 实现消息队列 用Vs2017创建一个控制台应用程序.创 ...

  4. 【网络编程基础】Linux下进程通信方式(共享内存,管道,消息队列,Socket)

    在网络课程中,有讲到Socket编程,对于tcp讲解的环节,为了加深理解,自己写了Linux下进程Socket通信,在学习的过程中,又接触到了其它的几种方式.记录一下. 管道通信(匿名,有名) 管道通 ...

  5. 持久化消息队列memcacheq的安装配置

    MemcacheQ 是一个基于 MemcacheDB 的消息队列服务器. 一.memcacheq介绍 特性: 1.简单易用 2.处理速度快 3.多条队列 4.并发性能好 5.与memcache的协议兼 ...

  6. 深入浅出 消息队列 ActiveMQ(转)

    一. 概述与介绍 ActiveMQ 是Apache出品,最流行的.功能强大的即时通讯和集成模式的开源服务器.ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provide ...

  7. 007. 服务间通信 RPC &amp; REST over HTTP(s) &amp; 消息队列

    服务间通信 服务间通信的几种方式: RPC.REST over HTTP(s).消息队列.  https://www.jianshu.com/p/2a01d4383d0b RPC https://bl ...

  8. 消息队列之 ActiveMQ(山东数漫江湖)

    简介 ActiveMQ 特点 ActiveMQ 是由 Apache 出品的一款开源消息中间件,旨在为应用程序提供高效.可扩展.稳定.安全的企业级消息通信. 它的设计目标是提供标准的.面向消息的.多语言 ...

  9. 深入浅出 消息队列 ActiveMQ------增强版

    本小节我们将讲解Apache开源下的ActiveMQ,而ActiveMQ是JMS的一个具体实现.JMS即Java消息服务(Java Message Service)应用程序接口是一个Java平台中关于 ...

随机推荐

  1. Objective-C中的单例模式

    ​    ​单例模式算是设计模式中比较简单的一种吧,设计模式不是只针对某种编程语言,在C++, Java, PHP等其他OOP语言也有设计模式,笔者初接触设计模式是通过<漫谈设计模式>了解 ...

  2. oracle中的nvl(), nvl2()函数

    nvl()函数是oracle/plpgsql中的一个函数,格式为:nvl(string1, replace_with) 功能:如果string1 位null,那么nvl()函数返回replace_wi ...

  3. phpexcel的写操作将数据库中的数据导入到excel中

    这个版本据说是可以支持excel2007,但是我使用2007编辑的xlsx是无法获得该库的支持.于是乎我就将它转化为2003.感觉支持地很好. 下面介绍一下具体的使用: require_once('. ...

  4. HTML---常见标签与插入背景音乐;

     插入背景音乐 (一).基本语法: embed src=url 说明:embed可以用来插入各种多媒体,格式可以是 Midi.Wav.AIFF.AU.MP3等等, Netscape及新版的IE 都支持 ...

  5. 写Java程序让Jvm崩溃

    package jvm; public class HeapCrash { public static void main(String[] args) { //Object[] o = {“abc” ...

  6. POI操作EXCEL之导出Excel(设置有效性,下拉列表引用)

    本人使用的是poi-bin-3.10-FINAL-20140208.zip 版本的poi以下是程序关键代码: //需要引用的类 import java.io.File; import java.io. ...

  7. div中的相对定位与绝对定位

    1.position:relative; 如果对一个元素进行相对定位,首先它将出现在它所在的位置上.然后通过设置垂直或水平位置,让这个元素“相对于”它的原始起点进行移动.(再一点,相对定位时,无论是否 ...

  8. C# 语法五 单例类、单例模式

    1.优点 只有一个实例 2.缺点 a)这个实例不能随时释放掉,占用资源. b)每次使用,都要判断是否为空,增加消耗 3.适用场景 只能有一个实例的业务场景,例如:数据库连接对象(每次连接都是同一个连接 ...

  9. Python之道(一)之安装Python

    "Python之道"首先介绍一下在windows系统下怎样安装Python开发环境. (1)下载MSI安装文件 进入网址www.python.org,点击Downloads进入下载 ...

  10. Oracle掌管权限和角色

    转自:https://blog.csdn.net/without_bont/article/details/79862112 掌管权限和角色 这一部分我们主要看oracle中如何管理权限和角色,权限和 ...