我的服务器将来自客户端的请求注册为多个请求

编程问答 2022-04-20

问题描述

我使用 Dart 和 Flutter 客户端应用程序制作了一个简单的 WebSocket 服务器。运行客户端应用程序时，服务器出于某种原因将连接注册为多个请求。我搜索了一段时间，但无法弄清楚为什么会这样。这可能是什么原因造成的？

服务器代码：

import 'dart:io' show HttpServer,HttpRequest,WebSocket,WebSocketTransformer;

void main() {
  var sockets = <WebSocket>[];
  var i = 0;

  HttpServer.bind('localhost',8080).then((server) {
    print('[+]WebSocket listening at -- ws://localhost:8080/');
    server.listen((HttpRequest request) {
      print('request made');

      WebSocketTransformer.upgrade(request).then((WebSocket ws) {
        sockets.add(ws);
        print('added a socket to the list');
        ws.listen(
          (data) {
            print(data);
            for(var socket in sockets) {
              socket.add('a msg back from the server: $i');
              print('msg sent to the client');
            }
            i++;
          },onDone: () => print('[+]Done :)'),onError: (err) => print('[!]Error -- ${err.toString()}'),cancelOnError: true
        );
      },onError: (err) => print('[!]Error -- ${err.toString()}'));

    },onError: (err) => print('[!]Error -- ${err.toString()}'));
  },onError: (err) => print('[!]Error -- ${err.toString()}'));
}

客户端代码：

import 'package:Flutter/material.dart';
import 'package:web_socket_channel/web_socket_channel.dart';

class ChangingText extends StatefulWidget {
  final _channel = WebSocketChannel.connect(
    Uri.parse('ws://localhost:8080/')
  );

  @override
  _ChangingTextState createState() => _ChangingTextState();
}

class _ChangingTextState extends State<ChangingText> {
  String _text = '';
  WebSocketChannel _channel = WebSocketChannel.connect(
    Uri.parse('ws://localhost:8080/')
  );

  _ChangingTextState() {
    _text = 'press me';
    _channel.stream.listen((data){
      setState(() {_text = data;});
      print(data);
    });
  }

  @override
  Widget build(BuildContext context) {

    return Column(children: [
      ElevatedButton(
        child: Text(_text),onpressed: (){widget._channel.sink.add("msg from the Flutter client!");},),]);
  }
}

class App extends StatelessWidget {
  const App({ Key? key }) : super(key: key);

  @override
  Widget build(BuildContext context) {
    return MaterialApp(home: Scaffold(body:
      ChangingText()
    ));
  }
}

void main() {
  runApp(App());
}

预先感谢您的帮助！

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

dartdart-serverserverserver