Flutter局域网广播(UDP通信)与TCP通信

🕗 发布于 2024-09-20 05:41 flutter udp tcp/ip

前言

现在有一个需求，手机和ESP32通过WIFI进行通信。流程如下：

手机创建TCP服务器
手机向192.168.0.255的1002端口广播自己的ip地址以及TCP服务器的端口号
ESP32监听到1002的广播内容后，连接手机的TCP服务器。
最后就是ESP32硬件和TCP服务器进行数据收发

因此我们要了解Flutter如何使用UDP进行广播、如何创建TCP服务器以及通过TCP进行通信

验证工具

假如我们代码写好了，和硬件直接调试发现出现了错误，我们就无法定位是Flutter的代码问题还是硬件的问题。因此需要一个验证工具来验证是哪方面出现了问题

这里我们使用验证工具是“山外多功能调试助手”

模拟TCP服务器

打开山外多功能调试助手
点击网络调试助手，再点击TCP服务器

输入端口号点击监听，硬件根据ip地址和端口号进行连接，在消息区我们可以看到是否有设备连接

ESP32能够连接这个软件说明错误问题在手机程序中

模拟TCP客户端

前端创建好了TCP服务端后，可以通过这个软件进行连接测试
打开“山外多功能调试助手”，点击网络调试助手，点击TCP客户端
输入服务器IP地址以及端口号，点击连接后查看消息是否连接成功

如果能够连接成功则说明我们的TCP服务器创建成功

模拟UDP广播

点击网络调试助手——>点击UDP，输入广播的端口号后点击连接
手机程序发送一个广播，在消息区可以看到广播的内容

创建TCP服务器

要在Flutter中创建TCP服务器，您可以使用dart:io库中的ServerSocket类。

下面代码使用ServerSocket.bind()方法绑定服务器的地址和端口。然后，我们使用server.listen()来监听来自客户端的连接。当客户端连接到服务器时，我们打印连接信息并向客户端发送欢迎消息。

接下来，我们通过socket.listen()来监听客户端发送的数据。当接收到数据时，我们打印收到的消息，并向客户端发送回复消息。如果在接收数据时出现错误或客户端断开连接，我们关闭与客户端的连接。

startServer() async {
  try {
    _serverSocket?.close();
    _serverSocket = await ServerSocket.bind(InternetAddress.anyIPv4, 5556);
    print( '服务器已启动，地址:${_serverSocket?.address.address}:${_serverSocket?.port}');
    _serverSocket?.listen(serverOnReceive);
  } catch (e, stackTrace) {
    print('e---------:$e');
  }
}
serverOnReceive(Socket socket) {
  _socket = socket;
  print('客户端已连接: ${socket.remoteAddress}:${socket.remotePort}');
  socket.writeln('欢迎连接到服务器'); // 向客户端发送欢迎消息
 
  _socket?.listen(
    (data) {
      print('接收到客户端消息: $data');
      socket.writeln('服务器收到消息: $data'); // 回复客户端收到的消息
    },
    onError: (error) {
      print('接收数据时出现错误: $error');
      socket.close(); // 关闭与客户端的连接
    },
    onDone: () {
      print('客户端已断开连接');
      socket.close(); // 关闭与客户端的连接
    },
  );
}

局域网广播

权限设置

android

在Flutter中发送广播消息所涉及的权限取决于您的目标平台和网络环境。以下是一些常见的权限，您可能需要在Flutter应用程序中配置以发送广播消息：

对于Android平台：

android.permission.INTERNET：用于访问互联网。
android.permission.ACCESS_NETWORK_STATE：用于访问网络状态信息。
android.permission.ACCESS_WIFI_STATE：用于访问Wi-Fi状态信息。
android.permission.CHANGE_WIFI_MULTICAST_STATE：用于更改Wi-Fi多播状态。

对于ios平台

NSLocalNetworkUsageDescription：描述应用程序使用本地网络的目的，添加该键值对到应用程序的Info.plist文件中。

示例Info.plist文件中的键值对配置部分：

<key>NSLocalNetworkUsageDescription</key>

<string>需要使用本地网络以发送广播消息。</string>

具体代码

在Flutter中，可以使用dart:io库中的RawDatagramSocket类来发送广播消息。以下是一个简单的示例代码，演示如何在Flutter中发送广播消息：

void sendBroadcastMessage() {
  String message = 'BB192.168.0.174:5556';
  print(utf8.encode(message));
  RawDatagramSocket.bind(InternetAddress.anyIPv4, 0)
      .then((RawDatagramSocket socket) {
    rawDatagramSocket = socket;
    var broadcastAddr = InternetAddress('255.255.255.255');
    var port = 1002; // 广播目标端口
 
    socket.broadcastEnabled = true;
 
    socket.send(utf8.encode(message), broadcastAddr, port);
 
    socket.close();
  }).catchError((error) {
    print('发送广播消息时出现错误: $error');
  });
}

全部代码

import 'dart:convert';
import 'dart:io';
 
import 'package:flutter/material.dart';
 
ServerSocket? _serverSocket;
Socket? _socket;
RawDatagramSocket? rawDatagramSocket;
 
class TCPServe extends StatefulWidget {
  const TCPServe({super.key});
 
  @override
  State<TCPServe> createState() => _TCPServeState();
}
 
class _TCPServeState extends State<TCPServe> {
  startServer() async {
    print("InternetAddress.anyIPv4:${InternetAddress.loopbackIPv4}");
    try {
      _serverSocket?.close();
      // _serverSocket = await ServerSocket.bind("localhost", 1234);
      _serverSocket = await ServerSocket.bind(InternetAddress.anyIPv4, 5556);
 
      print(
          '服务器已启动，地址: ${_serverSocket?.address.address}:${_serverSocket?.port}');
      _serverSocket?.listen(serverOnReceive);
    } catch (e, stackTrace) {
      print('e---------:$e');
    }
  }
 
  serverOnReceive(Socket socket) {
    _socket = socket;
    print('客户端已连接: ${socket.remoteAddress}:${socket.remotePort}');
    socket.writeln('欢迎连接到服务器'); // 向客户端发送欢迎消息
 
    _socket?.listen(
      (data) {
        print('接收到客户端消息: $data');
        socket.writeln('服务器收到消息: $data'); // 回复客户端收到的消息
      },
      onError: (error) {
        print('接收数据时出现错误: $error');
        socket.close(); // 关闭与客户端的连接
      },
      onDone: () {
        print('客户端已断开连接');
        socket.close(); // 关闭与客户端的连接
      },
    );
  }
 
  clean() async {
    await _socket?.close();
    print("_socket关闭");
    await _serverSocket?.close();
    print("_serverSocket关闭");
  }
 
  void sendBroadcastMessage() {
    String message = 'BB192.168.0.174:5556';
    print(utf8.encode(message));
    RawDatagramSocket.bind(InternetAddress.anyIPv4, 0)
        .then((RawDatagramSocket socket) {
      rawDatagramSocket = socket;
      var broadcastAddr = InternetAddress('255.255.255.255');
      var port = 1002; // 广播目标端口
 
      socket.broadcastEnabled = true;
 
      socket.send(utf8.encode(message), broadcastAddr, port);
 
      socket.close();
    }).catchError((error) {
      print('发送广播消息时出现错误: $error');
    });
  }
 
  cleanRawDatagramSocket() {
    rawDatagramSocket?.close();
  }
 
  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: const Text("TCP服务端测试")),
      body: Center(
        child: Column(
          children: [
            TextButton(
              onPressed: startServer,
              child: const Text("创建服务"),
            ),
            TextButton(
              onPressed: clean,
              child: const Text("关闭服务"),
            ),
            TextButton(
              onPressed: () {
                _socket?.writeln('REVERSE_LED');
              },
              child: const Text("发送REVERSE_LED"),
            ),
            TextButton(
              onPressed: sendBroadcastMessage,
              child: const Text("开始广播"),
            ),
            TextButton(
              onPressed: cleanRawDatagramSocket,
              child: const Text("关闭广播"),
            ),
          ],
        ),
      ),
    );
  }
}

原文地址：https://blog.csdn.net/nonagontech/article/details/142341660

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：git使用方法详解(适合新手)
下一篇：阿里通义千问开源Qwen2.5系列模型：Qwen2-VL-72B媲美GPT-4

2024年网络安全（黑客技术）三个月自学手册
网络安全可以基于攻击和防御视角来分类，我们经常听到的 “红队”、“渗透测试” 等就是研究攻击技术，而“蓝队”、“安全运营”、“安全运维”则研究防御技术。走安全行业的工程方向的，技术上面其实有很大的重叠
阅读更多2024-11-15
数据结构Python版
2.3.3 双链表双链表和链表一样，只不过每个节点有两个链接——一个指向后一个节点，一个指向前一个节点。此外，除了第一个节点，双链表还需要记录最后一个节点。每个结点为DLinkNode类对象，包括存储
阅读更多2024-11-15
连接数据库导出数据库信息支持excel pdf html markdown
1. java -jar运行后连接数据库即可，支持多种数据库。2.支持多种导出格式。
阅读更多2024-11-15
【解决】Layout 下创建槽位后，执行 Image 同步槽位位置后表现错误的问题。
开发平台：Unity 6.0编程语言：CSharp编程平台：Visual Studio 2022。
阅读更多2024-11-15
乐理的学习（简谱过渡五线谱）
调号在五线谱开头标注多个“♯”或“♭”每个“♯”或“♭”对应一个音符位置的升降，比如：C大调（无升降）是自然大调的基础形式，不需要额外调号。G大调：在调号中添加一个“F♯”，表示所有的F都要弹F♯。D
阅读更多2024-11-15
CSS回顾-颜色单位详解
本文介绍了 CSS 中的颜色单位相关知识。包括颜色名称、十六进制颜色值、RGB、RGBA、HSL、HSLA 等颜色单位的表示方式、特点及使用场景。还阐述了颜色单位之间（颜色名称与十六进制、十六进制与
阅读更多2024-11-15
Spring Boot中集成Redis与MySQL
用途：将键或简单的值序列化为字符串。适用场景：通常用于键的序列化，确保键在 Redis 中以字符串存储，以便于直接查看和管理。用途：将对象序列化为 JSON 格式的字符串，并支持 JSON 反序列化回
阅读更多2024-11-15
linux配置nginx
状态如果是Active: active (running)则是正常的。
阅读更多2024-11-15
C03S04-Linux网络之软件仓库、SSH和NFS
SSH是一种安全通道协议，主要用于远程登录到服务器、执行远程命令、传输文件以及管理服务器等。默认的端口号是TCP/22。NFS（网络文件系统，Network File System）是一种件系统协议，
阅读更多2024-11-15
无人机飞手在保家卫国上重要性技术详解
无人机飞手通过操作无人机上的通信设备，可以将侦察到的情报信息及时传输给指挥系统，同时也可以接收指挥系统的指令进行任务调整。无人机飞手经过专业培训，不仅掌握了无人机在不同气候、地形条件下的飞行技巧，还具
阅读更多2024-11-15