《项目Github地址》：https://github.com/jingzhanwu/flutter_jstomp

《项目pub地址》：https://pub.dev/packages/jstomp

之前项目上有使用到Stomp协议封装的websocket，端上使用订阅通道的形式，支持ws与http，支持订阅多个通道， JStomp是我基于当前项目中的使用和总结开发的一个FLutter 插件，一般中小型的项目中有消息推送，IM等业务场 景增加进入，下面具体看一下怎么接入。

一、提供的能力

1、支持ws方式连接

2、支持http方式连接

3、支持连接时的自定义验证参数，如token等

4、支持同时订阅多个点对点通道

5、支持同时订阅多个广播通道

6、提供连接、消息、发送等回调监听

7、支持发送消息时的自定义消息头

8、JStomp为单例设计，避免多次初始化和订阅

9、可不手动断开连接，程序重新进入重新初始化处理，不会多次订阅

10、轻量级接入，使用简单

11、自动管理心跳，无需使用者自己发送心跳维持长连接

12、支持AndroidX

13、连接失败或者断开连接后默认重试15分钟，重试间隔10秒

二、使用

1、引用

1561620483(1).jpg

当前稳定版本为1.1.0，具体版本可以不pub官网地址：https://pub.dev/packages/jstomp

2、stomp初始化，JStomp类本身是单例，

获取JStomp实例对象，或者直接使用JStomp.instance,或者JStomp()都是可以

  String userId = "1044521635390701569";
    ///初始化连接url
    String url =
        "ws://192.168.1.222:9999/message/websocket?personId=" + userId;

    ///开始初始化,参数senUrl：为发送消息的url
    bool b =
        await stomp.init(url: url, sendUrl: "/groupMessage/sendMessage");

初始化成功会返回true，失败则false,根据初始化结果做下面的几部操作

3、打开stomp连接

if (b) {
///打开stomp连接
  await stomp.connection((open) {

///连接成功打开回调
    print("连接打开了...$open");

  }, onError: (error) {

///打开错误回调
    print("连接打开错误了...$error");

  }, onClosed: (closed) {

///连接关闭时回调
    print("连接打开错误了...$closed");

  });
}

有三个回调方法，可以在对应的回调方法中处理相应的逻辑：

open：连接打开成功时回调，参数为bool类型，值为true或者false

error：打开连接错误时回调，参数为String类型，表示错误信息

closed：连接关闭时回调，参数为bool类型，值为true或者false

4、订阅消息通道，可以订阅点对点或者广播通道，都支持同时订阅多个地址

  ///点对点订阅地址
  final String p2p = "/groupMessage/" + userId;

  ///开始订阅点对点通道
  await stomp.subscribP2P([p2p]);

  ///订阅广播通道
  await stomp.subscribBroadcast(["广播通道1...", "广播通道2..."]);

5 、添加消息监听器，在消息监听器中监听消息的接收

      ///添加消息监听器
      await stomp.onMessageCallback((message) {

        ///点对点消息回调
        print("收到p2p新消息：" + message.toString());

      }, onBroadCast: (cast) {

        ///广播消息回调
        print("收到新广播消息：" + cast.toString());

      });

回调过来的参数message和cast是一个json格式的字符串，根据返回的结果进行解析即可。

6、添加消息发送监听器，发送消息结果回调

    ///添加发送消息监听器
    await stomp.onSendCallback((status, sendMsg) {

      ///消息发送结果回调，不管发送失败还是成功都会回调，
      ///参数 status:代表发送状态，是个枚举类型
      print("消息发送完毕：$status :msg=" + sendMsg.toString());

    });

同样的回调结果的sendMsg为json格式的字符串。

7、发送消息

  ///
  /// 发送消息
  ///
  Future<String> sendMsg() async {

    ///构造消息体，这里为一个Map
    Map<String, dynamic> msg = {
      "content": "flutter消息",
      "createId": "1143077861691756546",
      "createName": "牛不二",
      "createTime": "2019-06-27 17:03:51",
      "id": "1046324312976343042",
      "microGroupId": "1143049991384731649",
      "microGroupName": "flutter讨论群",
      "type": 0
    };

    ///stomp消息头，默认不需要，这里自定义一个
    Map<String, dynamic> head = {
      "userId": "p123456",
      "token": "MgjkjkdIdkkDkkjkfdjfdkjfk",
    };

    ///开始发送
    return await stomp.sendMessage(json.encode(msg), header: head);
  }

发送消息的方法为：sendMessage(),包含两个参数，第一个参数是必选参数，为消息体（json格式字串）;第二个参数为可选参数，根据业务需要可以自定义stomp头，比如token，user验证等。

8、stomp断开连接，并销毁资源

  ///
  /// 断开连接，并销毁资源
  ///
  Future<bool> _destroy() async {

    if (stomp == null) {
      return true;
    }

    bool b = await stomp.destroy();
    stomp = null;
    return b;
  }

destroy方法不但会断开stomp的连接，停止stomp服务，并且会销毁stomp的客户端与相关资源，所以一般是在程序退出或者确定要销毁服务的地方调用。

《Flutter 中sqlite使用》：https://blog.csdn.net/qq_19979101/article/details/93030803

《Flutter 状态管理之Redux》：https://blog.csdn.net/qq_19979101/article/details/92645385