[移动开发]Flutter 中 Dio 和 Socket 发送 和 接收 Protobuf 数据

Dio 使用 proto

1. 在pubspec.yaml 安装 dio

dio: ^4.0.6

2. 编译protobuf文件

   proto转为dart

3. 发送和接收proto, 可以根据个人的需求，进行封装

// 定义一个方法
static ProPost (Function callBack) async {
	var proto = SearchUserInfoRequest.create();  //  SearchUserInfoRequest 为proto中的message
	var userinfo = HttpUserInfo.create();
	var url = ""; // Ip:Prot
	userinfo.userGuid = "22222";
	userinfo.userName = "jack";
	Uint8List buf = userinfo.writeToBuffer();
	Options option = Options(
		headers: {
			Headers.contentTypeHeader: "application/x-www-form-urlencoded",
			Headers.accepHeader: "*"
		},
		method:"POST",
		contentType:"application/x-www-form-urlencoded",
		responseType: ResponseType.bytes,
	);
	var dio  = Dio();
	try {
		final response = await dio.request(url,options:option,data:buf);
		// 获取到的数据，通过指定的message 解析
		DevicesAndGroupsMessage tlcs = DevicesAndGroupsMessage.fromBuffer(response.data);
	} on DioError catch (e) {
		var ei = e.response?.data;
		print(ei.runtimeType); // Uin8List
		// 个人特殊需求
		TlcsErrorRequest tlcs = TlcsErrorRequest.fromBuffer(ei);
		return tlcs;
	}
	return;
	callBack(tlcs);
}

4. 修改dio插件
   进入dio.dart 文件中找到

late Transformer transformer;

然后进入transformer.dart文件,修改transformRequest这个方法，
我们会发现在transformRequest中 数据必须是 String ，我们需要数据为Uint8List，dio仅仅只是data.toString(),显然这样是不支持发送Uint8List数据的，因此我们修改一下

修改前：

// 26行
Future<String> transformRequest(RequestOptions options);

// 72行
  @override
  Future<String> transformRequest(RequestOptions options) async {
    var data = options.data ?? '';
    if (data is! String) {
      if (Transformer.isJsonMimeType(options.contentType)) {
        return json.encode(options.data);
      } else if (data is Map) {
        options.contentType =
            options.contentType ?? Headers.formUrlEncodedContentType;
        return Transformer.urlEncodeMap(data);
      }
    }
    return data.toString();
  }

修改后

// 26行
Future<String> transformRequest(RequestOptions options);

// 72行
  @override
  Future<String> transformRequest(RequestOptions options) async {
    var data = options.data ?? '';
    if (data is! String) {
	      if (Transformer.isJsonMimeType(options.contentType)) {
	        return json.encode(options.data);
	      } else if (data is Map) {
	        options.contentType =
	            options.contentType ?? Headers.formUrlEncodedContentType;
	        return Transformer.urlEncodeMap(data);
	      } else if(data is Uint8List) {
	        /*
	        return data;
	        github上，我见也有人直接 return data;直接返回Uint8List类型
	        我自己试了一下，在未知的位置又报错了，因此可以使用 String.fromCharCodes()
	        */ 
			return String.fromCharCodes(data);
		  }
    }
    return data.toString();
  }

Socket 使用 proto

1. 在pubspec.yaml 安装 web_socket_channel

web_socket_channel: ^1.1.0

2. 编译protobuf文件

   proto转为dart

3. 发送和接收proto, 可以根据个人的需求，进行封装

// 简单一个类
class ProtoMsg {
	static late Socket channel;
	// 创建连接
	static createWs(Ip,Prot) async {
		await Socket.connect(Ip,Prot,timeout: const Duration(seconds:10)).then((value) {
			channel = value;
			channel.asBroadcastStream();
		}).catchError((onError) {
		    // 连接失败，重连
			createWs(Ip,Prot);
		});
	}
	// 关闭连接
	static void dispos() {
		channel.close();
	}
	// 发送数据
	static writeData(buffer) async {
	    /*
	    	* 头标记 code(4个字节) ： 10000
	    	* 数据大小 (4个字节) ： leng
	    	* 保留大小 (4个字节) ： 保留
	    	* 数据内容 leng个字节
		*/
	    /*
		    // 特殊操作，有关于dart字节的操作
			var leng = buffer.length; // 获取到proto数据的长度
			ByteData bdata = ByteData(12 + leng); // 前12个字节预留位置，后面的字节为proto的数据
			var id = await ByteData.view(bdate.buffer, 0 , 4); //0位开始，4个字节，用于填写code值
			id.setUint32(0,10000); // 设置 code值
			var length = await ByteData.view(bdata.buffer,4,4); // 4位开始，4个字节，设置proto数据的长度
			length.setUint32(0,leng); // 设置 proto的长度
			var body = await ByteData.view(bdata.buffer,12,buffer.length); // 12位开始，proto数据字节长度，设置proto的数据
			for(var i = 0;i<leng;i++) {
				body.setUint8(i,buffer[i]); // 设置proto数据
			}
			var buf = Uint8List.view(body.buffer);
			channel.add(buf);
		 */
		channel.add(buffer);
	}
	static onReceiver(event) {
		print(event);
		ProtoMsg.parseData(event);
	}
	static parseData(Uint8List event) async {
		/*
	    	* 头标记 code(4个字节) ： 10000
	    	* 数据大小 (4个字节) ： leng
	    	* 保留大小 (4个字节) ： 保留
	    	* 数据内容 leng个字节
		*/
	    /*
		    // 特殊操作，有关于dart字节的操作
		    Uint8List id = event.sublist(0,4); // 截取前4个字节
			var data = event.sublist(12);
			var number = await ByteData.view(id.buffer).getInt32(0); // 获取到code值
			if(number == 500) {
				TlcsErrorRequest tlcs = TlcsErrorRequest.fromBuffer(data); // 反序列化数据
			}
		*/
		
		TlcsErrorRequest tlcs = TlcsErrorRequest.fromBuffer(event);
	}
  }
	// 使用方式
	ProtoMsg.createWs("","");
	var userinfo = HttpUserInfo.create();
	userinfo.userGuid = "22222";
	userinfo.userName = "jack";
	Uint8List buf = userinfo.writeToBuffer();// 序列号数据
	ProtoMsg.channel.listen(onReceiver);  // 接收到数据
	ProtoMsg.writeData(buf); // 发送数据