国内做网站公司排名,微信公众号的字体和wordpress,千库网会员,网站建设大概多少费用Flutter开发进阶之使用Socket实现主机服务（二）
Flutter开发进阶之使用Socket实现主机服务（一） 在完成局域网内设备定位后就可以进入微服务的实操了。
I、构建Socket连接池
一、定义Socket
使用socket_io_client
socket_io_client: ^2.0.3+1导入头文件
import packag…Flutter开发进阶之使用Socket实现主机服务（二）
Flutter开发进阶之使用Socket实现主机服务（一） 在完成局域网内设备定位后就可以进入微服务的实操了。
I、构建Socket连接池
一、定义Socket
使用socket_io_client
socket_io_client: ^2.0.3+1导入头文件
import 'package:socket_io_client/socket_io_client.dart' as io;定义属性
class _SocketIoObject {/// 连接io.Socket? socket; /// 连接次数int count = 0; /// 创建的时间int createTime = 0; /// 根据连接频率获取的优先级double proportion = 0;
}二、定义连接池
class SocketIoPool {/// 连接池本身static MapString, dynamic sockets = {}; /// 连接最大数量static int maxCount = 10; /// 根据优先级获取到/// 最应该销毁的连接的keystatic String exitKey = "";
}三、连接池运行逻辑
连接排序
/// 将连接按照优先级排序
/// 使用频率越低的连接的优先级越高
/// 可以被销毁
///
static void _sortSocket() {int now = DateTime.now().millisecondsSinceEpoch;double maxProportion = 0;sockets.forEach((key, value) {value.proportion = (now - value.createTime) / value.count;if (value.proportion maxProportion) {maxProportion = value.proportion;exitKey = key;}});}连接创建
/// 创建新连接时限制最大连接数量
///
static io.Socket _newSocket(String host, int port) {if (sockets.length = maxCount exitKey.isNotEmpty) {_SocketIoObject? object = sockets[exitKey];if (object != null) {object.socket?.disconnect();object.socket?.dispose();sockets.remove(exitKey);}}String relative = "$host:$port";io.Socket socket = io.io(relative);sockets[relative] = _SocketIoObject()..socket = socket..count = 1..createTime = DateTime.now().millisecondsSinceEpoch;Future(() = _sortSocket());
