Flutter实时通信插件socket_io_adapter的使用

当然，关于在Flutter项目中使用socket_io_adapter插件来实现实时通信，这里提供一个简单的代码案例来展示如何集成和使用该插件。需要注意的是，socket_io_adapter可能并不是Flutter社区广泛认知的官方或主流插件名称，这里假设你是指使用socket_io_client_dart（一个流行的Dart/Flutter Socket.IO客户端库）来实现Socket.IO通信。

首先，确保你的Flutter项目中已经添加了socket_io_client_dart依赖。在pubspec.yaml文件中添加以下依赖：

dependencies:
  flutter:
    sdk: flutter
  socket_io_client_dart: ^2.0.0-beta.4 # 请检查最新版本号

然后运行flutter pub get来安装依赖。

接下来，在你的Flutter应用中实现Socket.IO客户端功能。以下是一个简单的示例代码，展示如何连接到Socket.IO服务器、发送和接收消息。

import 'package:flutter/material.dart';
import 'package:socket_io_client_dart/socket_io_client_dart.dart' as IO;

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

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Socket.IO Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: SocketIOScreen(),
    );
  }
}

class SocketIOScreen extends StatefulWidget {
  @override
  _SocketIOScreenState createState() => _SocketIOScreenState();
}

class _SocketIOScreenState extends State<SocketIOScreen> {
  IO.Socket? socket;
  TextEditingController _messageController = TextEditingController();
  List<String> _messages = [];

  @override
  void initState() {
    super.initState();
    connectToSocket();
  }

  void connectToSocket() {
    String url = 'http://your-socket-io-server-url:port'; // 替换为你的Socket.IO服务器URL
    socket = IO.io(url, <String, dynamic>{
      'transports': ['websocket'],
    });

    socket!.onConnect((data) {
      print('Connected to socket server');
      _addMessage('Connected to server');
    });

    socket!.onDisconnect((data) {
      print('Disconnected from socket server');
      _addMessage('Disconnected from server');
    });

    socket!.on('message', (data) {
      print('Received message: $data');
      _addMessage('Server: $data');
    });

    socket!.onError((error) {
      print('Socket error: $error');
    });
  }

  void _sendMessage() {
    String message = _messageController.text;
    if (message.isNotEmpty) {
      socket!.emit('message', message);
      _addMessage('You: $message');
      _messageController.clear();
    }
  }

  void _addMessage(String message) {
    setState(() {
      _messages.add(message);
    });
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Flutter Socket.IO Demo'),
      ),
      body: Padding(
        padding: const EdgeInsets.all(8.0),
        child: Column(
          crossAxisAlignment: CrossAxisAlignment.start,
          children: <Widget>[
            Expanded(
              child: ListView.builder(
                itemCount: _messages.length,
                itemBuilder: (context, index) {
                  return Padding(
                    padding: const EdgeInsets.symmetric(vertical: 4.0),
                    child: Text(_messages[index]),
                  );
                },
              ),
            ),
            TextField(
              controller: _messageController,
              decoration: InputDecoration(
                border: OutlineInputBorder(),
                labelText: 'Enter message',
              ),
              onSubmitted: _sendMessage,
            ),
            ElevatedButton(
              onPressed: _sendMessage,
              child: Text('Send'),
            ),
          ],
        ),
      ),
    );
  }

  @override
  void dispose() {
    socket?.disconnect();
    _messageController.dispose();
    super.dispose();
  }
}

在这个示例中：

1. 我们首先添加了socket_io_client_dart依赖。
2. 在SocketIOScreen组件中，我们初始化并连接到Socket.IO服务器。
3. 我们处理了连接、断开连接和接收消息的事件。
4. 用户可以通过UI发送消息到服务器，并接收来自服务器的消息。

请确保将url变量替换为你的Socket.IO服务器的实际URL和端口。这个示例展示了基本的实时通信功能，你可以根据需求进一步扩展和定制。