订阅主题
Future<bool> subscribe(String topic) { throw UnimplementedError('subscribe() has not been implemented.'); }