flutter_chat_DAPP 去中心化聊天程序

这是一款致力于隐私保护的去中心化聊天的跨平台应用程序。

[TOC]

特性

去中心化
微服务架构
布局自适应
可拓展插件化
易扩展
模块化
接口化
本地化存储
存储及通信加密化，连接通讯更安全

下载

app下载分为：

server: 专门作为server
client: 主要为chat的客户端）
server_and_client: 集成server和client端于一体下载链接见release发行版本

系统架构

目录结构

说明：该项目基座基于flutter_app_all_template项目，具体目录结构请参阅该项目说明。因此本目录只详述microService目录

├─module          模块目录: 主要为调制service中server与client的调制整合模块
├─service         服务逻辑目录: 主要为除开UI部分的实现业务逻辑，主要面向后台逻辑处理，不进行UI交互处理
│  ├─client         client服务
│  └─server         server服务
└─ui              用户交互UI目录: 主要用户实现UI界面，调用service服务
    ├─client            单个client端应用
    │  ├─common           公共目录
    │  ├─component        组件目录
    │  ├─module           模块目录
    │  ├─page	          页面page目录
    │  └─widget           项目所有用到的widget目录
    ├─server	        单个server端应用	
    │  ├─common 
    │  ├─component
    │  ├─module
    │  ├─page
    │  └─widget
    └─server_and_client  server与client端整合应用
        ├─common
        ├─component
        ├─module
        ├─page
        └─widget

使用说明

技术栈

核心技术难点

去中心化实现

可拓展

通讯加解密

系统设计

模块划分

Server模块

新增自动处理其他类型消息

提示：每次在other目录下编写自定义消息类后，都要执行命令以进行自动代码生成

在目录/lib/microService/service/server/websocket/messageByTypeHandler下编写server端消息类型处理类

注意：文件名要与类型一致

类必选函数和参数

必选	类型	类别
type	MsgType	属性	枚举类型，具体见OtherMsgType.dart 自定义消息类别当客户端采用如下格式传输消息文本时，type类型名要与上面生成的枚举名一样
void handler(HttpRequest request, WebSocket webSocket, Map msgDataTypeMap)	function	方法	处理消息接收处理逻辑：接受参数msgDataTypeMap, clientObject

属性: String type

方法：

void handler(HttpRequest request, WebSocket webSocket, Map msgDataTypeMap) {
  //
}

完整：

/*
websocket  server与client通讯 自定义消息处理类: TEST消息类型
 */
import 'package:app_template/microService/service/server/websocket/other/TypeMessageClientHandler.dart';

class TestTypeWebsocketCommunication extends TypeWebsocketCommunication {
  MsgType type = MsgType.TEST;
  void handler(msgDataTypeMap, clientObject) {
    //
  }
}

其中TestTypeMessageServerHandler为实例文件类，按照该模版编写即可

运行该命令生成代码：切换到项目根目录下

dart run .\bin\genOtherServerMsgTypeClass.dart

消息类型与文件命名规则说明：

每一个文件名命名规则为: 驼峰命名消息类型 + TypeMessageHandler

代执行带生成的时候将会将TypeMessageHandler删除，留下剩余部分然后会按照如下规则生成消息枚举常量：

单驼峰：直接转变为大写形成枚举
多驼峰: 每个驼峰之间增加_, 然后再转为大写字母

例子：

单驼峰: TestTypeMessageHandler --> Test -->TEST
多驼峰: RequestInlineClientTypeMessageHandler--> RequestInlineClient --> Request_Inline_Client -->REQUEST_INLINE_CLIENT

提示：当客户端采用如下格式传输消息文本时，type类型名要与上面生成的枚举名一样

{
   "type": "REQUEST_INLINE_CLIENT", //必选字段,字母不区分大小写，Test = TEST = TeST
   .....  其他可选字段
}

注意： 对于具体的加解密算法没有提供，因为取决于client端加密的算法，如果client默认采用的本程序提供的普通消息加解密算法，可以直接调用基类TypeWebsocketCommunication中的enSecretMessage()和deSecretMessage()方法进行加解密，否则只能自己实现加解密算法。

关键核心代码 WebsocketServerManager类使用

// websocket client instance
WebsocketClientManager websocketClientManager = WebsocketClientManager();


// 启动server
websocketServerManager.setConfig(
    ip: AppConfig.ip,
    port: AppConfig.port,
    whenHasClientConnInterrupt:
    (WebsocketServerManager websocketServerManager,
     ClientObject clientObject) {
        // websocketServerManager  WebsocketServerManager对象
        // clientObject 中断的ClientObject对象
        printError("whenHasClientConnInterrupt: ${clientObject}");
    },
    whenServerError: (WebsocketServerManager websocketServerManager,
                      ErrorObject errorObject) {
        // websocketServerManager  WebsocketServerManager对象
        // errorObject 错误异常ErrorObject对象
        printError("whenServerError: ${errorObject}");
    });
// 启动server
websocketServerManager.boot();

Client模块

新增自动处理其他类型消息

提示：每次在other目录下编写自定义消息类后，都要执行命令以进行自动代码生成

在目录/lib/microService/service/client/websocket/other下编写server端消息类型处理类

注意：文件名要与类型一致

类必选函数和参数

必选	类型	类别
type	MsgType枚举类型	属性	自定义消息类别，当客户端采用如下格式传输消息文本时，type类型名要与上面生成的枚举名一样
void handler(WebSocketChannel? channel, Map msgDataTypeMap)	function	方法	处理消息接收处理逻辑：接受参数msgDataTypeMap

属性: String type

方法：

  void handler(WebSocketChannel? channel, Map msgDataTypeMap) {
    // 解密info字段
    msgDataTypeMap["info"] = decodeAuth(msgDataTypeMap["info"]);
    //处理逻辑
    auth(channel, msgDataTypeMap);
  }

完整：

/*
websocket  server与client通讯 自定义消息处理类: TEST消息类型
 */
class TestTypeMessageHandler extends TypeMessageClientHandler {
  MsgType type = MsgType.TEST;
  void handler(WebSocketChannel? channel, Map msgDataTypeMap) {
    //处理逻辑
  }
}

其中TestTypeMessageHandler为实例文件类，按照该模版编写即可

运行该命令生成代码：切换到项目根目录下

dart run .\bin\genCommunicationTypeClientModulatorClass.dart

提示：与server类似使用

注意： 对于具体的加解密算法没有提供，因为取决于client端加密的算法，如果client默认采用的本程序提供的普通消息加解密算法，可以直接调用基类TypeWebsocketCommunication中的enSecretMessage()和deSecretMessage()方法进行加解密，否则只能自己实现加解密算法

关键核心类WebsocketClientManager

// websocket client instance
WebsocketClientManager websocketClientManager = WebsocketClientManager();

// 启动client
websocketClientManager.setConfig(
ip: ip,
port: AppConfig.port,
whenConnInterrupt: (WebsocketClientManager websocketClientManager) {
//  websocketClientManager  WebsocketClientManager对象
printError("whenConnInterrupt: ${websocketClientManager}");
},
whenClientError: (ErrorObject errorObject) {
// errorObject 错误异常ErrorObject对象,聚体枚举参数见ErrorObject类
printError("whenClientError: ${errorObject}");
});
// 连接
websocketClientManager.conn();

manipulator调制器模块

strategy决策器模块

模型划分

功能体模型

层级模型

模块模型

一，公共类消息模块

参见详情代码逻辑

二，FTP类消息模块

系统架构图

技术栈选型

目录结构传输协议：采用socket双向传输协议，能进行主动传输。
文件传输协议: 有如下协议选择
1. http协议：被动
2. webscoket协议：主动
  
  文件存储策略：
3. 中心服务器托管：设计柔性，用户可选择中心服务器（充分保障用户信息安全）
4. 去中心化(客户端本地存储)存储：只依托于中心服务器作为文件传输的中转站(会进行加密，防止中心服务器劫持文件内容) 推荐

文件传输系统开发

系统架构图

设计要求

用户自行选择文件服务器：server端构建的文件服务器、自建的文件服务器、阿里云等官方存储文件服务
高安全性，信息传输链中仅仅通讯双方client才能有权限进行查阅，server中心文件服务器也无权查阅文件内容，充分保障用户隐私与安全。

HTTP system开发

数据库设计

用户表 (user)

用户表用来存储应用中所有用户的基本信息。

字段说明:

id: 用户的唯一标识符，通常是自增的整数。
username: 用户的用户名，必须是唯一的。
email: 用户的电子邮件地址，也必须是唯一的。
password_hash: 用户的密码哈希值，确保密码安全。
created_at: 账户创建时间戳。
updated_at: 用户信息的最近更新时间戳。
profile_picture: 用户的头像URL（可选）。
status: 用户当前的状态（在线、离线、勿扰等）（可选）

sql语句：

CREATE TABLE user (
    id SERIAL PRIMARY KEY,
    username VARCHAR(50) UNIQUE NOT NULL,
    email VARCHAR(100) UNIQUE NOT NULL,
    password_hash VARCHAR(255) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    profile_picture VARCHAR(255),
    status VARCHAR(50)
);

消息表 (chat)

消息表用来存储应用中所有的聊天消息。

字段说明:

id: 消息的唯一标识符，通常是自增的整数。
sender_id: 发送消息的用户ID，外键关联到 user 表的 id。
receiver_id: 接收消息的用户ID，外键关联到 user 表的 id。如果是群组聊天，可以用此字段存储群组ID。
content: 消息的文本内容。
created_at: 消息发送的时间戳。
is_read: 表示消息是否已被接收者阅读。
message_type: 消息的类型（文本、图片、文件等）。

sql语句：

CREATE TABLE chat (
    id SERIAL PRIMARY KEY,
    sender_id INT NOT NULL REFERENCES user(id) ON DELETE CASCADE,
    receiver_id INT NOT NULL REFERENCES user(id) ON DELETE CASCADE,
    content TEXT NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    is_read BOOLEAN DEFAULT FALSE,
    message_type VARCHAR(50) DEFAULT 'text'
);

表定义类

UserTable.dart 文件

ChatTable.dart文件

数据库设计细节与约束

关系与外键:
- chat 表中的 sender_id 和 receiver_id 都是 user 表的外键，这样可以确保每条消息都有有效的发送者和接收者。
- 使用 ON DELETE CASCADE 确保当用户被删除时，相关的消息也会被自动删除，避免孤立记录。
索引:
- 为 user 表的 username 和 email 字段创建唯一索引，以确保这些字段的唯一性。
- 为 chat 表中的 sender_id 和 receiver_id 创建索引，可以加快按用户查询消息的速度。
时间戳:
- created_at 字段记录了记录的创建时间，这在消息排序和用户注册时间上非常重要。
- updated_at 字段在 user 表中帮助记录最后的更新时间。
数据安全与隐私:
- password_hash 存储用户密码的哈希值而不是明文，增强了安全性。
- 对于聊天应用，保持数据的安全和隐私是至关重要的，确保对敏感数据的适当加密和保护。
扩展性:
- 可以在 user 表中添加更多的字段以支持附加功能（如用户的偏好设置、个人描述等）。
- 在 chat 表中，可以通过 message_type 字段扩展消息类型，以支持多媒体消息、文件等。

通讯websocket设计

websocket server服务端处理总消息队列的策略

被动触发：在listen中监听到消息时被动立即转发该消息，不需要建立新的线程专门处理消息队列，容易造成阻塞
循环任务：建立新线程专门处理消息队列，优点在于不会造成阻塞，难点在于怎样处理线程之间的通信

通讯方式：Queue队列存储形式

功能消息体设计

一、client客户端扫描scan

client端

{
	"type": "SCAN",
	"info": {
		"msg": "scan server task!"
	}
}

server端

{
	"type": "SCAN",
	"info": {
		"code": 200,
		"msg": "I am server for websocket!"
	}
}

二、客户端请求认证auth: 采用加密算法比较

算法规则: data_["info"]["key"] + data_["info"]["plait_text"]  使用md5加密生成encrypte

client端

{
	"type": "AUTH",
	"deviceId": "设备唯一性id",
	"info": {
		"plait_text": "vsdvsbvsavsdvdxbdbdxbfdbsbvdfbd",
		"key": "this is auth key for encode"，
        "encrypte": "sjkvsbkjdvbsdjvhbsjhvbdsjhvbsdjhvbsdjhvbsdvjs"
	}
}

server端返回

{
	"type": "AUTH",
	"info": {
		"code": "300",
		// 200 for successful !
		"msg": "this websocket client auth is not pass!"
	}
}

成功
{
	"type": "AUTH",
	"info": {
		"code": "200",
		// 代表成功
		"secret": secret,
		//通信秘钥
		"msg": "this websocket client auth is  pass!"
	}
}

三、通讯秘钥认证失败

{
	"type": "SECRET",
	"info": {
		"code": 400,
		"msg": "secret is not pass!"
	}
}

四、通用消息

{
	"type": "MESSAGE",
	"info": {
        "msgType": "text", // 消息类型: text,file,link......
		"sender": {
			"id": "user123",// 设备唯一标识
			// 发送者的唯一标识符
			"username": "Alice",
            "role":  "角色", // admin(管理员), agent(坐席), moderator(版主), user(用户)
			// 发送者用户名
			"avatar": "avatar.jpg" // 发送者头像（可选）
		},
		"recipient": {
			"id": "all", // 设备唯一标识
			// 接收者的唯一标识符，可以是 all 表示广播给所有用户， 
			"type": "group" // 接收者类型，例如 group 表示群组消息，user 表示私聊消息
		},
		"content": {
			"text": "Hello, World!",
			// 文本消息内容
			"attachments": [ // 附件列表，如图片、文件等（可选）
			{
				"type": "image",
				"url": "https://example.com/image.jpg",
				"name": "image.jpg"
			}]
		},
		"timestamp": "2024-06-14T15:30:00Z",
		// 消息发送时间戳
		"metadata": {
			"messageId": "msg123",
			// 消息的唯一标识符
			"status": "sent" // 消息状态，例如 sent, delivered, read
		}
	}
}

五、请求在线客户端client

client端发起请求

{
	"type": "REQUEST_INLINE_CLIENT",
	"info": {
		"deviceId": "",
		//请求客户端的设备唯一性id
	}
}

server端响应

{
	"type": "REQUEST_INLINE_CLIENT",
	"info": {
		"deviceId": [],// 在线设备唯一性id list，不包括本机deviceId
	}
}

六、server端主动广播在线的用户设计

触发点: 有新用户连接或有用户断开

函数设计：

server广播

 // 数据封装
Map msg = {
    "type": "BROADCAST_INLINE_CLIENT",
    "info": {"type": "list", "deviceIds": deviceIdList}
};

关键代码

  Future<void> receiveInlineClients() async {
    print("******************处理从server接收到的在线client***********************");
    // 1.获取deviceId 列表
    List<String> deviceIdList = msgDataTypeMap["info"]["deviceIds"];
    // 2.与数据库中对比:剔除一部分
    List deviceIdListInDatabase = await userChat.selectAllUserChat();
    Set<String> deviceIdList_set = deviceIdList.toSet();
    Set<String> deviceIdListInDatabase_set =
        deviceIdListInDatabase.map((e) => e.toString()).toSet();
    // 集合取交集
    Set<String> commonDeviceIds =
        deviceIdList_set.intersection(deviceIdListInDatabase_set);
    // 3.将其存入缓存中
    List<String> commonList = commonDeviceIds.toList();
    GlobalManager.appCache.setStringList("deviceId_list", commonList);
    // 4.创建为每个clientObject对象，采用list存储
    for (String deviceId in commonList) {
      // 判断全局变量中是否存在该队列
      if (!GlobalManager.userMapMsgQueue.containsKey("")) {
        // 不存在，创建
        GlobalManager.userMapMsgQueue[deviceId] = MessageQueue();
      }
    }

    printInfo("userMapMsgQueue count:${GlobalManager.userMapMsgQueue.length}");
  }

注: 根据该设计可知，以后聊天业务只需面向该map用户消息队列编程即可，便于解耦

七、扫码加好友设计

消息json设计

 {
     "type": "REQUEST_SCAN_ADD_USER",
     "info": {
         "type":"", // 类型：request、response  请求方还是相应方
         "status": "", //状态: agree、disagree,wait  消息状态，用于标识
         "confirm_key": "确认秘钥", // 确认秘钥，用于验证相应方是否有效，
         // 发送方：扫码方
         "sender": {"id": send_deviceId, "username": qr_map["username"], "avatar": “头像"},
         // 接收方: 等待接受
         "recipient": {"id": qr_map["deviceId"], "username": AppConfig.username, "avatar": “头像"},
         // 留言
         "content": qr_map["msg"] // 这个字段不是二维码扫描出的，而是用户自定义加上去的
     }
 }

八、群组设计

群组管理器模块类设计

server和client端各自继承该类实现具体逻辑

创建群组
删除群组
修改群组
查询群组
消息处理
消息加解密

通讯类型处理方案

方案一：分离式，单独为一个通讯类型模块

方案二：嵌入式，将其嵌入到通用消息类型中进

server服务端设计

。。。。。。

client客户端设计

数据库设计

目录结构

数据表设计

群组表

/*
desc: 定义数据库表结构:群组表
 */
import 'package:drift/drift.dart';

// 定义群组表
@DataClassName('Group')
class Groups extends Table {
  /// 自增的群组ID，唯一标识一个群组
  IntColumn get id => integer().autoIncrement()();

  /// 群组名称，必须唯一且长度在1到50个字符之间
  TextColumn get name => text()
      .withLength(min: 1, max: 50)
      .nullable()
      .customConstraint('NOT NULL UNIQUE')();

  /// 群组描述，可为空
  TextColumn get description => text().nullable()();

  /// 群组创建时间，默认为当前时间
  TextColumn get createdAt =>
      text().withDefault(Constant(DateTime.now().toIso8601String()))();

  /// 群组更新时间，默认为当前时间
  TextColumn get updatedAt =>
      text().withDefault(Constant(DateTime.now().toIso8601String()))();
}

用户群组关系表

/*
desc: 定义数据库表结构:用户群组关系表： 多对多
 */
import 'package:drift/drift.dart';

// 定义用户和群组之间的关系表
@DataClassName('UserGroupRelation')
class UserGroupRelations extends Table {
  /// 自增的关系ID，唯一标识一条关系
  IntColumn get id => integer().autoIncrement()();

  /// 用户ID，表示一个群组成员
  IntColumn get userId => integer()();

  /// 群组ID，表示用户所属的群组
  IntColumn get groupId => integer()();

  /// 用户是否为群组管理员
  BoolColumn get isAdmin => boolean().withDefault(Constant(false))();

  /// 用户加入群组的时间，默认为当前时间
  TextColumn get joinedAt =>
      text().withDefault(Constant(DateTime.now().toIso8601String()))();
}

数据表事务DAO操作

群组DAO

/*
desc: UserDao类DAO操作: DAO类集中管理 CRUD 操作
*/
import '../../microService/module/manager/GlobalManager.dart';
import '../LocalStorage.dart';
import 'BaseDao.dart';

class GroupDao implements BaseDao<Group> {
  // 查询数据
  Future<List> selectGroup(GroupsCompanion groupsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;

    // 构建查询
    final query = db.select(db.groups)
      ..where((tbl) => tbl.id.equals(groupsCompanion.id.value));
    // 获取查询结果
    final result = await query.get();

    // 将查询结果转换为 UserData 的列表
    return result.toList();
  }

  // 插入数据
  Future<dynamic> insertGroup(GroupsCompanion groupsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;

    // 构建
    final result = await db.batch((batch) {
      batch.insertAll(db.groups, [groupsCompanion]);
    });

    return result;
  }

  // 更新数据
  Future<int> updateGroup(GroupsCompanion groupsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;
    int result = 0;
    await db.update(db.groups)
      ..where((tbl) => tbl.id.equals(groupsCompanion.id.value))
      ..write(groupsCompanion).then((value) {
        print("update result: $value");
        result = value;
      });

    return result;
  }

  // 删除数据
  int deleteGroup(GroupsCompanion groupsCompanion) {
    // 获取database单例
    var db = GlobalManager.database;
    // 删除条数
    int result = 0;
    db.delete(db.groups)
      ..where((tbl) => tbl.id.equals(groupsCompanion.id.value))
      ..go().then((value) {
        print("delete data count: $value");
        result = value;
      });

    return result;
  }
}

用户群组DAO

/*
desc: UserDao类DAO操作: DAO类集中管理 CRUD 操作
*/
import '../../microService/module/manager/GlobalManager.dart';
import '../LocalStorage.dart';
import 'BaseDao.dart';

class UserGroupRelationDao implements BaseDao<UserGroupRelation> {
  // 查询数据
  Future<List> selectUserGroupRelation(
      UserGroupRelationsCompanion userGroupRelationsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;

    // 构建查询
    final query = db.select(db.userGroupRelations)
      ..where((tbl) => tbl.id.equals(userGroupRelationsCompanion.id.value));
    // 获取查询结果
    final result = await query.get();

    // 将查询结果转换为 UserData 的列表
    return result.toList();
  }

  // 插入数据
  Future<dynamic> insertUserGroupRelation(
      UserGroupRelationsCompanion userGroupRelationsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;

    // 构建
    final result = await db.batch((batch) {
      batch.insertAll(db.userGroupRelations, [userGroupRelationsCompanion]);
    });

    return result;
  }

  // 更新数据
  Future<int> updateUserGroupRelation(
      UserGroupRelationsCompanion userGroupRelationsCompanion) async {
    // 获取database单例
    var db = GlobalManager.database;
    int result = 0;
    await db.update(db.userGroupRelations)
      ..where((tbl) => tbl.id.equals(userGroupRelationsCompanion.id.value))
      ..write(userGroupRelationsCompanion).then((value) {
        print("update result: $value");
        result = value;
      });

    return result;
  }

  // 删除数据
  int deleteUserGroupRelation(
      UserGroupRelationsCompanion userGroupRelationsCompanion) {
    // 获取database单例
    var db = GlobalManager.database;
    // 删除条数
    int result = 0;
    db.delete(db.userGroupRelations)
      ..where((tbl) => tbl.id.equals(userGroupRelationsCompanion.id as int))
      ..go().then((value) {
        print("delete data count: $value");
        result = value;
      });

    return result;
  }
}

server消息任务调度设计

矩阵式调度client的消息进入总线的消息队列

调度策略：

横向(client调度)：按重要度进行调度选取（何为重要性则需要自行选取）
纵向(消息调度)：单个client客户端消息队列设计，一般采用时间先后顺序。

创新调度方法：采用人工智能调度

总消息队列设计

在线client消息队列
离线client消息队列：负责各类的离线信息调度，进入其消息队列的msg的info字段已进行加密处理

根据message所标识的接受者信息[这里采用设备的唯一id作为依据]选择其对应clientObject对象，这里有个策略选择：如果接受者处于断线状态怎么处理，如下策略解决，推荐策略1，这里选择权交给用户，用户自行选择策略策略1: 采用建立一个离线状态信息的循环队列用于被动发送/主动发送，这里最好的策略为在用户连接成功server端后调用该循环信息队列,这会增加server端的存储压力策略2:采用互信机制，只能在双方都处于在线状态时才能进行通讯，

关于离线消息队列两个核心点：

未在在线clientObject中找到的消息clientObject是否进入离校消息队列中
是否开启离线消息队列，这里采用策略被动触发离线消息队列处理机制

进入离线消息队列msg需要满足的字段条件：

 {
     "type":"",
     "info":{
         // 接收者
         "recipient":{
             "id":"设备唯一性ID"
             .......
         },
         ........
     }
 }

离线消息加密设计：两道加密防护

第一道：内存加密存储防护，自定义秘钥为key为该机的唯一性设备标识符作为加密秘钥key
第二道：传输解密防护,双方互信生成的秘钥key

Client端接收好友添加消息队列

加密与加密

UI界面

消息页面缓存设计

为每个通讯对象实体(普通用户、群主)设计一个用于缓存新消息的队列。只需要面向队列变成即可。

应用启动时，根据拥有用户数创建消息队列，关闭应用时清空消息队列

server端作为client设计

方案

方案一(目前方案): 本地重启一个client客户端实例，server与client服务分离

好处：有力减少server与client的耦合，跟有利于分别维护server与client的代码，简单

缺点: 增加server的中心设备的性能压力，不太推荐
方案二(推荐,后续方案): 共用server的websokcet，但是需要修改部分代码，这里需要设计server与client的桥接通道类

好处: 只需要利用server的websocket与client的通讯，有力较少其中心设备的能耗

坏处: 其造成server与client代码交织在一起，耦合性强

解决方法: 通过合理的代码设计有力较少server与client的代码耦合性

通过重写

要点：

消息不需要加解密
采用原client基础上通过判断的方式

离线消息新解决方案，采用Hive存储消息并发送：好友添加和离线消息

开发日历

server端离线消息队列调度存在问题，消息文本加解密问题
离线消息队列待解决，出现bug，无法正常运行。addUser调度

开发日志

2024-7-23 创建并初始化项目
2024-7-25 重构项目：但是存在一个bug，在小米9手机上关闭应用无法调用中端程序，另外手机正常调用了中断程序，小米9存在延迟，需要对方发送MESSAGE消息后才后调用终端程序。已解决！
2024-7-30 替换核心websocket，使用dart包flutter_websocket_simple包。
2024-8-5 修复scan扫描add user bug，并重新整合项目新架构，优化项目结构
2024-8-10 增加msi构建模块，并设置应用图标
2024-8-12 修复websoketClient snd 关闭server无法广播在线在线client bug
2024.8.19 修复server端离线消息缓存本地存储，存在bug，第一个离校消息由于对方没有断线离开而损失。
2024.8.20 新增server_UI的日志信息记录功能模块

导入包modal_bottom_sheet存在依赖冲突: 隐藏material中的ModalBottomSheetRoute
2024.8.21 新增server端插件系统，支持dart插件化支持，并修复面板显示bug

采用dart_plugin_system项目开发，具体开发文档参见仓库https://github.com/gnu-xiaosong/dart_plugin_system

同时将flutter版本升级到20.xx版本

提示：目前插件系统的注入点还没有注入，因此目前插件模块开发还不能使用，暂时作为功能性阅览，后期将会补充完善并编写对应开发文档。
2024.8.21 新增ws模块，用于显示socket信息处理类别模块
2024.8.23 新增聊天UI设置：自定义背景图像
2024.8.26 新增本地启动Http server服务主要用于聊天文件请求,但存在bug，当Android切换应用时，httpserver会自动关闭，进入又能自动启动。
2024.8.26 新增client端聊天图片支持，并支持图片阅览缩放等操作,重构部分代码
2024.8.27 新增发送图片支持,并优化httpserver，后续将会持续新增语音和文件支持，后续优化点: 将资源在获取的http连接下载在本地存储，并及时删除服务器中转的资源文件，保障用户隐私。目前图片暂时在服务端存储,后续后改进优化"
2024.12.04 开始群组设计........

Name		Name	Last commit message	Last commit date
Latest commit History 22 Commits
android		android
assets		assets
bin		bin
harmony		harmony
ios		ios
jsons		jsons
lib		lib
linux		linux
macos		macos
project		project
test		test
web		web
windows		windows
.gitignore		.gitignore
.metadata		.metadata
README.md		README.md
_config.yml		_config.yml
analysis_options.yaml		analysis_options.yaml
app_analisys_size.json		app_analisys_size.json
devtools_options.yaml		devtools_options.yaml
pluginSystem.md		pluginSystem.md
pubspec.lock		pubspec.lock
pubspec.yaml		pubspec.yaml
tree.txt		tree.txt

Folders and files

Latest commit

History

Repository files navigation

flutter_chat_DAPP 去中心化聊天程序

特性

下载

系统架构

目录结构

使用说明

技术栈

核心技术难点

去中心化实现

可拓展

通讯加解密

系统设计

模块划分

Server模块

新增自动处理其他类型消息

关键核心代码 WebsocketServerManager类使用

Client模块

新增自动处理其他类型消息

关键核心类WebsocketClientManager

manipulator调制器模块

strategy决策器模块

模型划分

功能体模型

层级模型

模块模型

一，公共类消息模块

二，FTP类消息模块

系统架构图

技术栈选型

文件传输系统开发

系统架构图

设计要求

HTTP system开发

数据库设计

用户表 (user)

消息表 (chat)

数据库设计细节与约束

通讯websocket设计

通讯方式：Queue队列存储形式

功能消息体设计

一、client客户端扫描scan

二、客户端请求认证auth: 采用加密算法比较

三、通讯秘钥认证失败

四、通用消息

五、请求在线客户端client

六、server端主动广播在线的用户设计

七、扫码加好友设计

八、群组设计

群组管理器模块类设计

通讯类型处理方案

方案一： 分离式，单独为一个通讯类型模块

方案二：嵌入式，将其嵌入到通用消息类型中进

server服务端设计

client客户端设计

数据库设计

目录结构

数据表设计

数据表事务DAO操作

server消息任务调度设计

总消息队列设计

进入离线消息队列msg需要满足的字段条件：

离线消息加密设计：两道加密防护

Client端接收好友添加消息队列

加密与加密

UI界面

消息页面缓存设计

server端作为client设计

离线消息新解决方案，采用Hive存储消息并发送：好友添加和离线消息

开发日历

开发日志

About

Resources

Uh oh!

Stars

Watchers

Forks

方案一：分离式，单独为一个通讯类型模块

Packages