Flutter Isolate仅接收初始消息 controlPort发后续消息无响应

后续消息无法接收是两个核心错误导致的：

• 错用了消息发送端口：isolate.controlPort是Isolate运行时内部专用的控制端口，只用来处理暂停、恢复、终止Isolate这类系统级操作，不会把你发送的自定义业务消息投递到你写的入口处理函数中，你发的"Bar"、"Test"消息根本没有进入业务逻辑层。
• 子Isolate没有配置持续监听、也没有保持存活状态：你写的入口函数是一次性执行逻辑，接收到初始化传入的Animal("Foo")、执行完print语句后就直接运行结束了。Dart Isolate的事件循环如果没有被活跃任务持有（比如打开的ReceivePort、未完成的IO任务、活跃的定时器），会直接自动退出，后续就算消息发对了端口，子Isolate已经销毁，自然无法接收。

另外你看到的输出顺序异常（先打印Sending bar/Sending test，再打印received Foo），是因为await Isolate.spawn只会在子Isolate创建完成时返回，不会等待入口函数执行完毕，你拿到isolate实例立刻发消息时，子Isolate还没跑到处理初始参数的步骤，时序错乱也会导致消息丢失。

如果只需要跑一次性的后台任务，不需要后续和子Isolate交互，直接用Isolate.run或者Flutter内置的compute函数即可，不需要手动管理端口。
如果需要和子Isolate持续双向通信，必须手动建立基于ReceivePort和SendPort的消息通道，步骤如下：

1. 主Isolate先创建自己的ReceivePort，用来接收子Isolate回传的消息
2. 启动子Isolate时，把主Isolate的SendPort作为初始参数传给子Isolate入口；如果需要同时传初始业务数据，可以把SendPort和业务数据封装为同一个对象传入
3. 子Isolate入口内先处理初始业务数据，再创建自己的ReceivePort用来监听主Isolate发来的消息，同时把自己的SendPort通过主Isolate传过来的端口发回给主Isolate
4. 主Isolate拿到子Isolate回传的SendPort后，再通过这个端口发送后续业务消息
5. 子Isolate侧只要ReceivePort不关闭，就会一直保持存活，持续监听消息
6. 用完记得关闭端口、销毁Isolate，避免内存泄漏

可直接运行的参考代码：

import 'dart:isolate';
import 'dart:io';

class Animal {
  final String name;
  Animal(this.name);
}

// 封装Isolate初始化参数，同时传递主Isolate端口和初始业务数据
class IsolateInitParams {
  final SendPort mainSendPort;
  final Animal initialAnimal;
  IsolateInitParams(this.mainSendPort, this.initialAnimal);
}

// 子Isolate入口必须是顶级函数或者类的静态方法，不能是实例方法
void childIsolateEntry(IsolateInitParams params) {
  // 先处理初始传入的业务参数
  print('received ${params.initialAnimal.name}');
  // 子Isolate创建自己的消息接收端口
  final childReceivePort = ReceivePort();
  // 把子Isolate的发送端口回传给主Isolate，完成通道建立
  params.mainSendPort.send(childReceivePort.sendPort);

  // 持续监听主Isolate发来的消息
  childReceivePort.listen((message) {
    if (message is Animal) {
      print('received ${message.name}');
    }
  });
}

void main() async {
  // 主Isolate创建接收端口
  final mainReceivePort = ReceivePort();
  // 启动子Isolate，传入封装好的初始化参数
  final isolate = await Isolate.spawn(
    childIsolateEntry,
    IsolateInitParams(mainReceivePort.sendPort, Animal("Foo"))
  );

  SendPort? childSendPort;
  // 主Isolate监听消息，先等子Isolate回传它的发送端口
  mainReceivePort.listen((message) {
    if (message is SendPort && childSendPort == null) {
      childSendPort = message;
      // 通道建立完成后再发业务消息，避免时序问题丢消息
      print('Sending bar');
      childSendPort!.send(Animal("Bar"));

      print('Sending test');
      childSendPort!.send(Animal("Test"));
    }
  });

  // 等待查看输出
  sleep(const Duration(seconds: 10));
  // 资源释放
  mainReceivePort.close();
  isolate.kill();
}

注意事项 #

• 跨Isolate传递的自定义对象需要支持序列化，复杂嵌套类建议手动实现序列化方法，避免传递报错
• 不要在子Isolate中操作主Isolate持有的UI对象、非线程安全的变量，两个Isolate是完全内存隔离的
• 长驻子Isolate如果不需要使用了必须主动kill，否则会一直占用后台资源

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