用阿波罗服务器订阅时GraphQL订阅异常

Question

GraphQL订阅抛出异常“ Web套接字连接失败” 使用Apollo服务器订阅时。订阅与GraphQl Explorer合作正常，但是在扑面

代码中实现时失败，下面附加了异常。

**********代码

final _wsLink = WebSocketLink(    
  ‘***************’,    
  config: SocketClientConfig(
    autoReconnect: true,
    inactivityTimeout: Duration(hours: 1),
    // delayBetweenReconnectionAttempts: Duration(seconds: 1),
  ),  
); 

final Link _link = Link.split((request) => request.isSubscription, _wsLink, httpLink);
     
client = GraphQLClient(     
  cache: GraphQLCache(store: InMemoryStore()),
  link: _link,  
);

SubscriptionOptions options = SubscriptionOptions(
  document: gql(query),
  variables: variables);

final result = client.subscribe(options);

result.listen((event) {
  print("Event fired ${event.data}");
  print("Event fired ${event.exception?.graphqlErrors.toString()}");
}).onError((e) {
  print("Received Error ! ${e.toString()}");
});

return result;

***************************************************************************************************************

i/flutter（5204）：与Websocket断开连接。

Answer 1

我迟到了，但这对我有用，如果您有阿波罗服务器4

final HttpLink httpLink = HttpLink(
    'http://192.168.43.29:4000/graphql', // my localhhost
  );
  
   final AuthLink authLink = AuthLink(
      getToken: () async => 'Bearer $token',
    );
    Link link = authLink.concat(httpLink);

    WebSocketLink websocketLink = WebSocketLink(
      'ws://192.168.43.29:4000/graphql/subscriptions', // my localhhost
      config: SocketClientConfig(
          autoReconnect: true,
          inactivityTimeout: const Duration(seconds: 30),
          initialPayload: {
            'token': token,
          },
          ),
      subProtocol: GraphQLProtocol.graphqlTransportWs, // This line is important, by default protocol is GraphQLProtocol.graphqlWs
    );

    if (websocketLink != null) {
      link =
          Link.split((request) => request.isSubscription, websocketLink, link);
    }

    graphqlClient = ValueNotifier(
      GraphQLClient(
        link: link,
        cache: GraphQLCache(store: HiveStore()),
      ),
    );