现在可以在媒体库页面添加nipaplay远程访问。现在远程访问可以扫描局域网直接发现。修复了C键发送弹幕不会暂停视频的bug。2025.1220

Author: MCDFsteve

Documentation/server-integration.md

@@ -15,7 +15,7 @@
 
 **设置步骤**：
 1. **PC端开启共享**：在设置 → 远程访问 → 启用web服务器
-2. **移动端连接**：输入PC端的局域网地址（如：192.168.1.100:8080）
+2. **移动端连接**：在“共享媒体库”中点击“扫描局域网”选择设备；也可手动输入PC端局域网地址（如：192.168.1.100，默认端口 1180）
 3. **开始观看**：媒体库中会显示PC端的视频，可直接播放
 
 **优势**：

lib/pages/media_library_page.dart

@@ -366,7 +366,7 @@ class _MediaLibraryPageState extends State<MediaLibraryPage> {
           LoginField(
             key: 'baseUrl',
             label: '访问地址',
-            hint: '例如：http://192.168.1.100:1180',
+            hint: '例如：192.168.1.100（默认1180）或 192.168.1.100:2345',
           ),
         ],
         loginButtonText: '添加',

lib/providers/shared_remote_library_provider.dart

@@ -550,12 +550,35 @@ class SharedRemoteLibraryProvider extends ChangeNotifier {
 
   String _normalizeBaseUrl(String url) {
     var normalized = url.trim();
-    if (!normalized.startsWith('http://') && !normalized.startsWith('https://')) {
+    if (normalized.isEmpty) return normalized;
+
+    final hasScheme = normalized.contains('://');
+    if (!hasScheme) {
       normalized = 'http://$normalized';
     }
+
+    // 先去掉末尾斜杠，避免 Uri.parse 解析 path 导致的歧义。
     if (normalized.endsWith('/')) {
       normalized = normalized.substring(0, normalized.length - 1);
     }
+
+    try {
+      final uri = Uri.parse(normalized);
+
+      // 用户未显式指定端口时：若是局域网/本机地址，则默认走 NipaPlay 远程访问默认端口 1180。
+      if (!uri.hasPort &&
+          uri.scheme == 'http' &&
+          _shouldBypassProxy(uri.host)) {
+        normalized = uri.replace(port: 1180).toString();
+      }
+    } catch (_) {
+      // 若解析失败，保留原始输入（上层会在请求时给出错误提示）
+    }
+
+    if (normalized.endsWith('/')) {
+      normalized = normalized.substring(0, normalized.length - 1);
+    }
+
     return normalized;
   }
 

lib/services/nipaplay_lan_discovery.dart

@@ -0,0 +1,140 @@
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:flutter/foundation.dart';
+
+const int nipaplayLanDiscoveryPort = 32123;
+
+class NipaPlayLanDiscoveredServer {
+  const NipaPlayLanDiscoveredServer({
+    required this.ip,
+    required this.port,
+    this.hostname,
+  });
+
+  final String ip;
+  final int port;
+  final String? hostname;
+
+  String get baseUrl => 'http://$ip:$port';
+}
+
+class NipaPlayLanDiscoveryProtocol {
+  static const int protocolVersion = 1;
+
+  static const String requestType = 'nipaplay_discover';
+  static const String responseType = 'nipaplay_discover_response';
+
+  static Uint8List buildRequestBytes() {
+    return Uint8List.fromList(utf8.encode(json.encode(<String, dynamic>{
+      'type': requestType,
+      'v': protocolVersion,
+    })));
+  }
+
+  static Uint8List buildResponseBytes({required int webPort}) {
+    return Uint8List.fromList(utf8.encode(json.encode(<String, dynamic>{
+      'type': responseType,
+      'v': protocolVersion,
+      'app': 'NipaPlay',
+      'hostname': Platform.localHostname,
+      'os': Platform.operatingSystem,
+      'port': webPort,
+    })));
+  }
+
+  static bool isValidRequestPayload(Map<String, dynamic> payload) {
+    return payload['type'] == requestType && payload['v'] == protocolVersion;
+  }
+
+  static NipaPlayLanDiscoveredServer? tryParseResponse(Datagram datagram) {
+    final payload = _tryDecodeJson(datagram.data);
+    if (payload == null) return null;
+    if (payload['type'] != responseType) return null;
+    if (payload['v'] != protocolVersion) return null;
+    if (payload['app'] != 'NipaPlay') return null;
+
+    final rawPort = payload['port'];
+    final port = rawPort is int ? rawPort : int.tryParse(rawPort?.toString() ?? '');
+    if (port == null || port <= 0 || port > 65535) return null;
+
+    final hostname = payload['hostname'] is String ? payload['hostname'] as String : null;
+    return NipaPlayLanDiscoveredServer(
+      ip: datagram.address.address,
+      port: port,
+      hostname: hostname,
+    );
+  }
+
+  static Map<String, dynamic>? _tryDecodeJson(Uint8List data) {
+    try {
+      final decoded = json.decode(utf8.decode(data));
+      return decoded is Map<String, dynamic> ? decoded : null;
+    } catch (_) {
+      return null;
+    }
+  }
+}
+
+class NipaPlayLanDiscoveryResponder {
+  RawDatagramSocket? _socket;
+  int _webPort = 1180;
+
+  bool get isRunning => _socket != null;
+
+  Future<void> start({required int webPort}) async {
+    _webPort = webPort;
+    if (_socket != null) {
+      return;
+    }
+
+    try {
+      final socket = await RawDatagramSocket.bind(
+        InternetAddress.anyIPv4,
+        nipaplayLanDiscoveryPort,
+        reuseAddress: true,
+      );
+
+      socket.listen((event) {
+        if (event != RawSocketEvent.read) return;
+        Datagram? datagram;
+        while ((datagram = socket.receive()) != null) {
+          final payload = _tryDecodeJson(datagram!.data);
+          if (payload == null) continue;
+          if (!NipaPlayLanDiscoveryProtocol.isValidRequestPayload(payload)) continue;
+
+          final response = NipaPlayLanDiscoveryProtocol.buildResponseBytes(webPort: _webPort);
+          try {
+            socket.send(response, datagram.address, datagram.port);
+          } catch (_) {
+            // ignore send failures
+          }
+        }
+      });
+
+      _socket = socket;
+      debugPrint('NipaPlayLanDiscoveryResponder: started on UDP $nipaplayLanDiscoveryPort');
+    } catch (e) {
+      debugPrint('NipaPlayLanDiscoveryResponder: start failed: $e');
+    }
+  }
+
+  Future<void> stop() async {
+    try {
+      _socket?.close();
+    } catch (_) {
+      // ignore
+    } finally {
+      _socket = null;
+    }
+  }
+
+  static Map<String, dynamic>? _tryDecodeJson(Uint8List data) {
+    try {
+      final decoded = json.decode(utf8.decode(data));
+      return decoded is Map<String, dynamic> ? decoded : null;
+    } catch (_) {
+      return null;
+    }
+  }
+}