flutter 自定义websocket路由的实现

在 flutter websocket 中 服务端推送数据给客户端后 很多人的处理居然都是 if / switch; 感觉这样的写法不咋好!

自己想的一个办法:

在 lib 目录下新建一个 socket 目录 里面创建两个文件main.dart和router.dart;
main.dart : 主要控制websocket的连接 断开 和收到消息的处理;
router.dart 则为websocket 服务端返回的消息做路由处理;

router.dart

import 'package:lee/logic/user.dart';

typedef void routehandle(map params);

var wsrouter = new wsrouter();

class wsrouter {
 static map<string, routehandle> _routers = new map();

 init() {
  routers.foreach((route) {
   route.foreach((name, value) {
    this.add(name, value);
   });
  });
 }

 // 增加路由
 void add(string name, routehandle handle) {
  wsrouter._routers[name] = handle;
 }

 // 路由处理
 future<void> handle(string name, map params) async {
  routehandle handle = wsrouter._routers[name];
  if (handle == null) {
   print("路由不存在");
   return;
  }
  handle(params);
 }
}

list<map<string, routehandle>> routers = [
 {"login": userlogic.login},
 {"kick": userlogic.kick},
];

main.dart

import 'package:lee/socket/router.dart';
import 'package:web_socket_channel/io.dart';
import 'dart:convert';

var websocket = new websocket();

class websocket {
 // websocket连接
 iowebsocketchannel websocketchannel;

 factory websocket() => _websocket();

 static websocket _instance;

 // 构造函数
 websocket._() {
  // 初始化websocket路由
  wsrouter.init();
 }

 static websocket _websocket() {
  if (_instance == null) {
   _instance = websocket._();
  }
  return _instance;
 }

 conn() {
  iowebsocketchannel channel = new iowebsocketchannel.connect(
    "ws://127.0.0.1:8080/ws",
    pinginterval: duration(milliseconds: 100));

  channel.stream
    .listen((data) => onmessage(data), onerror: onerror, ondone: ondone);

  this.websocketchannel = channel;
 }

 onmessage(response) async {
  // 例如服务端返回的大概是这样一个json
  // {"cmd":"kick","data":{}}
  // {"cmd":"login","data":{}}
  map params = json.decode(response);
  wsrouter.handle(params["cmd"], params["data"]);
 }

 onerror(err) async {}

 ondone() async {}
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。