Flutter中PusherClient无法同时监听多集群的解决方案咨询

以下是几个可行的解决思路：

1. 绕过单例限制，创建多个独立的PusherClient实例 #

如果PusherClient的单例实现是通过工厂构造函数，但内部存在私有构造函数，可以直接调用私有构造来创建多个实例。如果第三方库不允许直接调用私有构造，也可以复制库的核心代码，修改单例逻辑为非单例模式，自行维护多个实例。

示例代码：

class MultiPusherManager {
  late PusherClient usClusterClient;
  late PusherClient euClusterClient;

  MultiPusherManager() {
    // 配置第一个集群（us2）
    final usOptions = PusherOptions(
      cluster: 'us2',
      auth: PusherAuth('your_us_api_key'),
    );
    // 调用私有构造创建实例（假设库的私有构造为_internal）
    usClusterClient = PusherClient._internal('your_us_api_key', usOptions);

    // 配置第二个集群（eu）
    final euOptions = PusherOptions(
      cluster: 'eu',
      auth: PusherAuth('your_eu_api_key'),
    );
    euClusterClient = PusherClient._internal('your_eu_api_key', euOptions);
  }

  void setupEventListeners() {
    // 监听us集群的频道事件
    usClusterClient.subscribe('us_channel').bind('us_event', (event) {
      // 处理us集群事件
    });

    // 监听eu集群的频道事件
    euClusterClient.subscribe('eu_channel').bind('eu_event', (event) {
      // 处理eu集群事件
    });
  }
}

2. 搭建中间层服务聚合事件 #

如果无法在客户端创建多个Pusher实例，可以在后端搭建一个中间服务，同时连接两个Pusher集群，将两个集群的事件统一转发到一个自定义的WebSocket或API接口，Flutter客户端只需要连接这个中间服务即可接收所有事件。

示例Node.js中间层代码：

const Pusher = require('pusher');
const WebSocket = require('ws');

// 初始化两个Pusher客户端
const pusherUs = new Pusher({
  appId: 'us_app_id',
  key: 'us_api_key',
  secret: 'us_api_secret',
  cluster: 'us2',
});

const pusherEu = new Pusher({
  appId: 'eu_app_id',
  key: 'eu_api_key',
  secret: 'eu_api_secret',
  cluster: 'eu',
});

// 创建WebSocket服务
const wss = new WebSocket.Server({ port: 8080 });

// 监听us集群事件并转发
pusherUs.subscribe('us_channel').bind('us_event', (data) => {
  wss.clients.forEach(client => {
    if (client.readyState === WebSocket.OPEN) {
      client.send(JSON.stringify({ source: 'us_cluster', event: 'us_event', data }));
    }
  });
});

// 监听eu集群事件并转发
pusherEu.subscribe('eu_channel').bind('eu_event', (data) => {
  wss.clients.forEach(client => {
    if (client.readyState === WebSocket.OPEN) {
      client.send(JSON.stringify({ source: 'eu_cluster', event: 'eu_event', data }));
    }
  });
});

Flutter端只需要连接这个WebSocket服务，接收并处理转发的事件即可。

3. 使用Isolate隔离多个Pusher实例 #

利用Dart的Isolate特性，在不同的Isolate中分别创建PusherClient实例。由于Isolate拥有独立的内存空间，单例类在不同Isolate中会被实例化为不同的对象，从而实现同时连接两个集群的需求。

示例代码：

import 'dart:isolate';

/// 在Isolate中运行的Pusher连接逻辑
void runPusherInIsolate(SendPort sendPort) {
  final options = PusherOptions(
    cluster: 'us2',
    auth: PusherAuth('your_us_api_key'),
  );
  final client = PusherClient('your_us_api_key', options);

  // 监听事件并发送到主Isolate
  client.subscribe('us_channel').bind('us_event', (event) {
    sendPort.send({
      'cluster': 'us2',
      'eventName': 'us_event',
      'data': event.data,
    });
  });

  client.connect();
}

void main() async {
  // 创建接收端口，用于接收Isolate发来的事件
  final receivePort = ReceivePort();
  
  // 启动Isolate连接第一个集群
  await Isolate.spawn(runPusherInIsolate, receivePort.sendPort);
  
  // 处理来自Isolate的事件
  receivePort.listen((message) {
    print('收到${message['cluster']}的事件：${message['eventName']}');
    // 业务逻辑处理
  });

  // 同理启动第二个Isolate连接eu集群
  // await Isolate.spawn(runEuPusherInIsolate, anotherReceivePort.sendPort);
}

内容的提问来源于stack exchange，提问作者Oscar