【2023】Kotlin教程第四篇项目实战第26章项目实战2：开发Kotlin版QQ聊天工具 26.4 任务3：编写服务器外围代码

柔光的暖阳◎ 2024-03-23 16:04 52阅读 0赞

### 【2023】Kotlin教程 ###

#### 文章目录 ####

*   *  【2023】Kotlin教程
     *   *  第四篇 项目实战
         *  第26章 项目实战2：开发Kotlin版QQ聊天工具
         *   *  26.4 任务3：编写服务器外围代码
             *   *  26.4.1 迭代3.1：创建数据表类
                 *  26.4.2 任务3.2：编写UserDAO类
                 *  26.4.3 任务3.3：编写ClientInfo类

![在这里插入图片描述][08255066694f44388dfd416c6b147e44.png_pic_center]

#### 第四篇 项目实战 ####

#### 第26章 项目实战2：开发Kotlin版QQ聊天工具 ####

##### 26.4 任务3：编写服务器外围代码 #####

服务器端外围代码主要是涉及到UserDAO和ClientInfo两个非通信类，还有DBSchema.kt文件，在该文件中声明了与数据库对应的数据表类。

###### 26.4.1 迭代3.1：创建数据表类 ######

使用Exposed框架还需要编写与数据库对应的数据表类。具体实现代码如下：

DBSchema.kt

package com.dingjiaxiong.server
    
    import org.jetbrains.exposed.sql.Table
    
    /**
     * @Projectname: QQ
     * @Classname: DBSchema
     * @Author: Ding Jiaxiong
     * @Data:2023/4/7 14:37
     */
    
    const val URL = "jdbc:mysql://localhost:3306/qq?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8"
    const val DRIVER_CLASS = "com.mysql.cj.jdbc.Driver"
    const val DB_USER = "root"
    const val DB_PASSWORD = "123456"
    
    /* 用户表 */
    object Users : Table() {
        
        //声明表中字段
    //    override val primaryKey = PrimaryKey(productid, name = "PK_Produc_ID")
    
        val user_id = varchar("user_id", length = 80)           /* 用户Id  */
        override val primaryKey = PrimaryKey(user_id, name = "PK_UserID")
    
        val user_pwd = varchar("user_pwd", length = 25)         /* 用户密码 */
        val user_name = varchar("user_name", length = 80)       /* 用户名 */
        val user_icon = varchar("user_icon", length = 100)      /* 用户头像 */
    }
    
    /* 用户好友表Id1和Id2互为好友 */
    object Friends : Table() {
        
        val user_id1 = varchar("user_id1", length = 10) /* 用户Id1  */
        val user_id2 = varchar("user_id2", length = 10) /* 用户Id2  */
        override val primaryKey = PrimaryKey(user_id1, user_id2, name = "PK_UserId1Id2")
    }

![在这里插入图片描述][5b82de2090e946e39013781144f98ad6.png_pic_center]

###### 26.4.2 任务3.2：编写UserDAO类 ######

UserDAO是操作数据库用户表的DAO对象，如下图所示类图中，

![在这里插入图片描述][236234ab15694bbebd2a6f52546ac88b.png_pic_center]

可见UserDAO有两个公有查询函数：

//按照主键查询
    fun findByld(id:String):Map<String,String>?
    //查询好友列表
    fun findFriends(id:String):List<Map<String,String>>?

findByld通过用户ID查询用户信息，查询返回的数据在Map中，本项目没有定义用户实体类，而是将用户信息放到Map集合中。findFriends是通过用户ld查询他的所有好友，返回的是List集合，其中的每一个元素都是Map。

UserDAO代码如下：

UserDAO.kt

package com.dingjiaxiong.server
    
    import org.jetbrains.exposed.sql.Database
    import org.jetbrains.exposed.sql.StdOutSqlLogger
    import org.jetbrains.exposed.sql.addLogger
    import org.jetbrains.exposed.sql.select
    import org.jetbrains.exposed.sql.transactions.transaction
    
    /**
     * @Projectname: QQ
     * @Classname: UserDAO
     * @Author: Ding Jiaxiong
     * @Data:2023/4/7 14:40
     */
    
    class UserDAO {
        
    
        // 按照主键查询
        fun findById(id: String): Map<String, Any>? {
        
    
            var list: List<Map<String, String>> = emptyList()
            //连接数据库
            Database.connect(URL, user = DB_USER, password = DB_PASSWORD, driver = DRIVER_CLASS)
            //操作数据库
            transaction {
        
                //添加SQL日志
                addLogger(StdOutSqlLogger)
                list = Users.select {
         Users.user_id.eq(id) }.map {
        
                    val row = mutableMapOf<String, String>()
                    row["user_id"] = it[Users.user_id]
                    row["user_pwd"] = it[Users.user_pwd]
                    row["user_name"] = it[Users.user_name]
                    row["user_icon"] = it[Users.user_icon]
                    //Lambda表达式返回数据
                    row
                }
            }
            return if (list.isEmpty()) null else list.first()
        }
    
        // 查询好友 列表
        fun findFriends(id: String): List<Map<String, Any>>? {
        
    
            var list: List<Map<String, String>> = emptyList()
            //连接数据库
            Database.connect(URL, user = DB_USER, password = DB_PASSWORD, driver = DRIVER_CLASS)
            //操作数据库
            transaction {
        
                //添加SQL日志
                addLogger(StdOutSqlLogger)
                val userList1 = Friends.slice(Friends.user_id2).select {
        
                    Friends.user_id1.eq(id)
                }.map {
        
                    it[Friends.user_id2]
                }
    
                val userList2 = Friends.slice(Friends.user_id1).select {
        
                    Friends.user_id2.eq(id)
                }.map {
        
                    it[Friends.user_id1]
                }
    
                list = Users.select {
        
                    Users.user_id.inList(userList1 + userList2)
                }.map {
        
                    val row = mutableMapOf<String, String>()
                    row["user_id"] = it[Users.user_id]
                    row["user_pwd"] = it[Users.user_pwd]
                    row["user_name"] = it[Users.user_name]
                    row["user_icon"] = it[Users.user_icon]
                    //Lambda表达式返回数据
                    row
                }
            }
            return list
        }
    }

![在这里插入图片描述][405318a7fa7b41ca9c2b6b350565dba3.png_pic_center]

###### 26.4.3 任务3.3：编写ClientInfo类 ######

一个用户可以在任何一个客户端主机上登录，因此登录的客户端主机IP和端口号都是动态的。为了在服务器端保存所有登录的用户Id,以及登录的客户端主机地址和端口号信息，所以设计了Clientlnfo类，具体内容见如下图所示类图。

![在这里插入图片描述][6f367d66dd8a46b3a332abaabd6ba7c6.png_pic_center]

ClientInfo代码如下：

ClientInfo.kt

package com.dingjiaxiong.server
    
    import java.net.InetAddress
    
    /**
     * @Projectname: QQ
     * @Classname: ClientInfo
     * @Author: Ding Jiaxiong
     * @Data:2023/4/7 14:42
     */
    
    data class ClientInfo(
        val port: Int,// 客户端端口号
        val address: InetAddress,// 客户端IP地址
        val userId: String
    )// 用户Id

![在这里插入图片描述][b8fe631482c24345a20ee2e74ca2dc79.png_pic_center]

[08255066694f44388dfd416c6b147e44.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/5ac8683940d34463ad6b5e823002c293.png
[5b82de2090e946e39013781144f98ad6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/4a277662c47c46898b5b77760a28f041.png
[236234ab15694bbebd2a6f52546ac88b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/f028140a640348cda2ce6440012ae3d3.png
[405318a7fa7b41ca9c2b6b350565dba3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/113aadd2b9754ae383858303e24be11f.png
[6f367d66dd8a46b3a332abaabd6ba7c6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/8b4752cbc72f48da8ef512177d12bba0.png
[b8fe631482c24345a20ee2e74ca2dc79.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/c213a3dbc1944250b3f7d8ecb000a885.png