flutter笔记-webrtc使用1:依赖本地包socket.io-client

文章目录

本文开始介绍webrtc的使用，阅读本文的前提是假设你已经使用过webrtc，了解webrtc的交互机制，不了解的可以看之前的文章：
WebRTC系列-WebRTC基础(四)连接建立时序图及运行机制，本文使用的信令服务是基于socketio 2.x的版本，所以下面介绍dart中如何本地依赖socket.io-client包；

通过本文你将学会如何添加本地的dart包到自己的项目，将了解如何使用socketio；

Dart大多数情况下都是直接适用pub的方式从网站下载下来使用。如果需要将源码下载到指定的目录去使用，就需要使用yaml添加本地依赖的方式了；这里使用socket.io-client-dart本地添加的方式介绍：

1. 示例工程

示例项目的配置如下：

也就是如下的文件关系：

...dart
........depends
...............socket.io-client-dart

2. yaml 修改

上面介绍了工程的文件夹结构，接着就需要修改主工程的yaml文件了；修改如下：

dependencies:
  http: ^1.2.1
  socket_io_client:
    path: ./depends/socket.io-client-dart/

这里的socket_io_client，是依赖项目yaml配置的包名；然后就是配置库的相对路径了；
之后执行 dart pub get或flutter pub get, 命令会自行下载socket_io_client中的库依赖。

3. 使用

在主项目的文件中使用和pub的方式一直：
1.引入头文件

import 'package:socket_io_client/socket_io_client.dart' as IO;

1. 调用示例：

voidmain(List<String> args)async{// 应用自定义的 HTTP Overrides// 创建 Socket.IO 客户端IO.Socket socket = IO.io('https://39.97.110.12:443',<String,dynamic>{'transports':['websocket'],// 指定使用 WebSocket 传输});// 连接到服务器
  socket.connect();// 监听连接事件
  socket.onConnect((_){print('Connected');
    socket.emit('join','123456');});// 监听收到的消息
  socket.on('event',(data)=>print(data));// 监听断开连接事件
  socket.onDisconnect((_)=>print('Disconnected'));// 监听来自服务器的消息
  socket.on('joined',(data){print('Joined:${data}');});
  socket.on('message',(data){print('Joined${data}');});// 监听连接错误事件
  socket.on('error',(data){print('Error');print(data);});

  socket.on("connect_error",(data)=>print('Connect error: $data'));}

上面的代码展示了socketio的简单使用；

4. socketio 关于自定义服务器自定义签名的问题

大多数我们测试的时候使用的都是自定义签名的https服务，这时候使用isocketo的client是连接不上的；需要配置如下：

classMyHttpOverridesextendsHttpOverrides{@overrideHttpClientcreateHttpClient(SecurityContext? context){returnsuper.createHttpClient(context)..badCertificateCallback =(X509Certificate cert,String host, int port){// 接受所有证书，包括自签名证书returntrue;};}}

然后在调用socketio前如下调用：

// 应用自定义的 HTTP OverridesHttpOverrides.global =MyHttpOverrides();

注意引入sdk依赖库

：import 'dart:io';

测试服务在git上：WebRTCDemo

dart测试展示：

封装成async和await方式

async和await 是类似java的一种同步的方式去异步低啊用方法，并等待返回的一种方式；这种方式的代码看起来会比较好；改造上面的代码如下：

Future<bool>SocketIOConnect(IO.Socket socket){Completer<bool> completer =Completer<bool>();// 监听连接事件
  socket.onConnect((_){sleep(Duration(milliseconds:100));print('Connected sucess!!!');
    completer.complete(true);// socket.emit('join', '123456');});// 监听连接错误事件
  socket.on('connect_error',(data){print('Connect error: $data');
    completer.complete(false);});// 监听连接超时事件
  socket.on('connect_timeout',(data){print('Connect timeout: $data');
    completer.complete(false);});// 返回 Future 对象return completer.future;}voidtestSocketIo()async{// 创建 Socket.IO 客户端IO.Socket socket = IO.io('https://39.97.110.12:443',<String,dynamic>{'transports':['websocket'],// 指定使用 WebSocket 传输});

  bool connected =awaitSocketIOConnect(socket);if(connected){print('Socket connected');
    socket.emit('join','123456');// 监听收到的消息
    socket.on('event',(data)=>print(data));// 监听断开连接事件
    socket.onDisconnect((_)=>print('Disconnected'));// 监听来自服务器的消息
    socket.on('joined',(data){print('Joined: $data');});
    socket.on('message',(data){print('Message: $data');});// 监听连接错误事件
    socket.on('error',(data){print('Error');print(data);});

    socket.on('connect_error',(data)=>print('Connect error: $data'));}else{print('Socket connection failed');}}