基于Linux系统聊天室增加数据库sqlite功能实现(08)

这篇具有很好参考价值的文章主要介绍了基于Linux系统聊天室增加数据库sqlite功能实现(08)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

全部掌握后,开始进入本篇。

一. 调整目录结构

为了方便编译,现在我们将前面文章的代码结构做如下调整。

root@ubuntu:/mnt/hgfs/code/chat# tree .
.
├── chat_client
│   ├── include
│   ├── Makefile
│   ├── obj
│   │   └── Makefile
│   └── src
│       ├── client.c
│       └── Makefile
├── chat.h
├── chat_server
│   ├── bin
│   │   └── server
│   ├── data
│   ├── include
│   ├── Makefile
│   ├── obj
│   │   └── server.o
│   └── src
│       ├── Makefile
│       └── server.c
└── gcc.sh

10 directories, 15 files

最终增加了数据的文件目录如下:

peng@ubuntu:/mnt/hgfs/code/chat-sqlite$ tree .
.
├── chat_client
│   ├── include
│   ├── Makefile
│   ├── obj
│   │   └── Makefile
│   └── src
│       ├── client.c
│       └── Makefile
├── chat.h
├── chat_server
│   ├── data
│   ├── include
│   │   └── data.h
│   ├── Makefile
│   ├── obj
│   │   └── Makefile
│   └── src
│       ├── data.c
│       ├── Makefile
│       └── server.c
├── clean.sh
├── gcc.sh
├── user.db
└── 解压密码.txt

9 directories, 17 files

clean.sh 用于清除临时文件gcc.sh 用于编译整个工程

服务端代码放置到chat_server目录下;客户端代码放置到chat_client目录下;

数据库相关代码放在chat_server/data下。

chat.h是所有客户端和服务器都会用到的头文件,所以放置在根目录下。

后续增加功能后,新增的头文件和C文件分别添加到对应工程目录的include和src目录下即可。

二、 设计数据库表

我们之前维护的所有客户端的信息是用一个全局数组,并且没有保存功能,现在我们要把所有客户端的信息全部保存到数据库中。

数据库存储的目录

chat_server/data

数据库名:

user.db

存储用户信息的表名:

user

表user格式如下:

名称 属性 说明
name TEXT PRIMARY KEY 用户名,不能重复
passwd TEXT NOT NULL 密码
fd INT NOT NULL 套接字描述符:-1表示不在线,>0表示在线
regist INT NOT NULL 用户名是否注册:-1没有注册,1注册

三、 主要功能操作的语句及函数

数据库操作最重要的就是语句,下面讲解针对不同的功能对应的实现语句

1 创建表user

CREATE TABLE IF NOT EXISTS user(name TEXT PRIMARY KEY  NOT NULL,passwd TEXT NOT NULL,fd INT NOT NULL,regist INT  NOT NULL);

2 增加一个用户

客户端发送注册请求后,服务器端注册用户信息到数据库中

数据库操作语句如下:

insert into user values('一口Linux', '123456',-1, 1)

功能函数如下:

int db_add_user(char name[],char passwd[])
功能:
增加一个用户,执行该函数前需要先判断该用户名是否存在

参数:
name:用户名
passwd:密码

返回值:
-1:失败
1:成功

3 判断用户是否在线

客户端发送登陆命令后,服务器通过该函数判断该用户是否已经登陆成功

数据库操作语句如下:

select fd from user where name='嵌入式Linux'

功能函数如下:

int db_user_if_online(char *name,char *passwd)
功能:
判断用户是否在线,该函数主要根据fd的值来判断用户是否在线

参数:
name:用户名
passwd:密码  

返回值:
1:在线
-1:不在线
-2:用户不存在

4 判断某个用户名是否注册

用户发送注册命令,服务器需要判断该用户名是否已经被注册过

数据库操作语句如下:

select regist from user where name='嵌入式Linux'

功能函数如下:

int db_user_if_reg(char *name)
功能:
判断某个用户名是否注册过

参数:
name:用户名

返回值:
 1:注册过
-1:没有注册过

5 判断用户名密码是否正确

用户发送登陆命令,需要判断用户名密码是否正确

数据库操作语句如下:

select * from user where name='嵌入式Linux' and passwd='123456'

功能函数如下:

int db_user_pwd_corrct(char *name,char* passwd)
功能:
判断客户端发送的用户名密码是否正确

参数:
name:用户名
passwd:密码

返回值:
 1:正确
-1:用户名或者密码不正确

6 用户上线、下线

用户登陆成功后,或者发送下线申请,或者异常掉线,需要更新数据库的状态。

数据库操作语句如下:

UPDATE  user set fd=-1 where name='嵌入式Linux'

fd的值是套接字描述符,下线设置为-1,上线设置为对应的>0的值

功能函数如下:

int db_user_on_off(int fd,char *name,unsigned int on_off) 
功能:
更新数据库中用户的fd字段

参数:
fd:套接字描述符
name:用户名
on_off:上线还是下线

返回值:
 1:正确
-1:失败

7. 显示在线用户

用户发送显示在线用户命令后,服务器从数据库当中查找所有在线用户,并将姓名循环发送给客户端

int db_list_online_user(int fd)

四、运行结果

编译

./gcc.sh

1.服务器启动

./server 9999

端口号设定为9999

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

2. 客户端注册

客户端启动

./client 127.0.0.1 9999

选择1  注册,输入用户名密码即可。

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

3. 用户登录

输入选项2,输入刚才注册的用户名密码,如果不一致会提示错误

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

登录成功:

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

4. 注册登录其他几个用户

注册并登录新的用户111、222、333

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

5. 公聊

选择选项3,即进入公聊, 用户yikou向所有用户说:hello!

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

可见所有用户均收到信息。

6. 私聊

用户yikou向用户111发送信息: 

由下图可知,只有用户111收到该信息,其他用户均没有收到信息。

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

7. 显示在线用户

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

8. 查看最终数据库信息

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

五、代码说明

为方便读者学习增加数据库和去掉数据之间的差别,

用git维护版本。

基于Linux系统聊天室增加数据库sqlite功能实现(08),Linux操作系统嵌入式开发之经典,数据库,oracle

切换到没有数据库的版本,执行下面命令即可。

git reset --hard  597330ae0a183c9db8f68b7c9f60df94f8965778

要切回有数据库的版本执行下面的命令:

git reset --hard 10bfbfaf2d09ae895313273c960ecfd84663f9fd

使用数据库后,数据的存储管理更加方便,数据类型更易于扩充, 逻辑关系也更加清晰。

获得完整代码, 直接访问https://gitee.com/wx_98fa5ee790/chat文章来源地址https://www.toymoban.com/news/detail-730202.html

到了这里,关于基于Linux系统聊天室增加数据库sqlite功能实现(08)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • JAVA基于局域网的聊天室系统的设计与实现

           本文介绍了采用JAVA编程开发视频聊天系统的一套比较常用的解决方案。文字聊天采用TCP模式;语音视频聊天采用UDP模式,在客户端之间点对点的进行。在该方案中,通过函数库VFW来实现视频捕获、影像压缩以及影像播放。微软公司提供的专门用于视频捕获开发的工具

    2023年04月15日
    浏览(38)
  • 网络聊天室的UDP实现以及数据库

    网络聊天室UDP实现 服务器端: 头文件: 主函数: 自定义函数: 客户端: 思维导图:

    2024年03月21日
    浏览(42)
  • Linux socket聊天室

    目录 一、运行效果 1、分别编译客户端和服务端代码 2、运行 3、使用效果  二、代码 chat.h 服务端代码  客户端代码 gcc client.c -o C -lpthread gcc server.c -o S -lpthread 先运行服务器端,8888为端口号 ./S 8888  再运行客户端,这里创建两个客户端,端口号要和服务端的一样 ./C 127.0.0.1

    2024年01月22日
    浏览(41)
  • 基于UDP实现的网络聊天室

    服务器: 客户端: 运行结果:

    2024年03月08日
    浏览(61)
  • 基于WebSocket的在线文字聊天室

    与Ajax不同,WebSocket可以使服务端主动向客户发送响应,本案例就是基于WebSocket的一个在线聊天室,不过功能比较简单,只能满足文字交流。演示如下。 案例学习于b站up主,链接 。这位up主讲的非常清楚,值得去学习。本文属于记录自我学习过程的文章。 项目目录下app.js 项

    2024年02月13日
    浏览(56)
  • 基于qt软件的网上聊天室软件

    1.服务器:         1).功能: 用于创建一个客户端,通过文本编辑器来获得端口号,根据获得的端口号创建服务器,等待客户端连接 创建成功会提示服务器创建成功 在收到客户端发送的信息时,把这条信息发送给其他所有客户端,实现群聊功能         2).代码: 2.客户端

    2024年02月09日
    浏览(43)
  • 基于Python web的多人聊天室

              本文介绍了基于即时通讯的Python实现web版多人聊天室的设计和实现。这个系统利用了多种先进的技术,如Django、Channels、WebSocket,来实现即时通信,并利用MySQL和Redis作为数据库,同时还采用了多种前端技术,如bootstrap、CSS、html和js,来提供出色的用户体验。该系

    2024年02月16日
    浏览(37)
  • 【项目设计】基于WebSocket的Web聊天室

    本项目的名称为Web聊天室,即类QQ群组聊天,多个用户可以在同一个群组收发消息进行聊天 项目实现的业务 注册功能:用户输入账号,密码,昵称,图像点击即可注册用户(账号和昵称不能重复) 登陆功能:用户输入账号,密码即可进行登陆(如果登陆的账号已在别处登陆

    2023年04月18日
    浏览(112)
  • 基于springboot与websocket实现简易聊天室

    创建一个简单聊天室的HTML和JavaScript代码,匹配相应的css样式,这个聊天室将使用WebSocket技术,允许用户实时发送和接收消息。 1.1 html和js代码 通过new WebSocket(url)建立一个新的websocket连接。websocket连接建立之后使用websocket.onopen,websocket.onclose,websocket.onerror等方法实时监测we

    2024年02月01日
    浏览(52)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包