Flutter应用程序能够发送数据到Docker容器中的UDP服务器，但无法接收来自服务器的数据

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《Flutter应用程序能够发送数据到Docker容器中的UDP服务器，但无法接收来自服务器的数据》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我目前正在 go 中开发后端 udp 服务，该服务与 flutter 移动应用进行通信。

这是 udp 服务代码：

package main

import (
    "log"
    "net"
    "os"
    "time"
)

func main() {
    port := ":8080"

    logger := log.new(os.stdout, "", log.ldate|log.ltime)

    udp_server, err := net.resolveudpaddr("udp4", port)

    if err != nil {
        logger.fatalln(err.error())
        return 
    }

    udp_connection, err := net.listenudp("udp4", udp_server)

    if err != nil {
        logger.fatalln(err.error())
        return 
    }

    defer udp_connection.close()

    buffer := make([]byte, 1024)

    for {
        n, addr, err := udp_connection.readfromudp(buffer)
        if err != nil {
            udp_connection.writetoudp([]byte("error reading from udp connection"), addr)
        }
        
        buffer_string := string(buffer[0:n])

        time_sent := time.now()
        time_sent_string := time_sent.string()
    
        combined_string := buffer_string + time_sent_string
        data := []byte(combined_string);
        logger.println(combined_string);

        _, err = udp_connection.writetoudp(data, addr)
        if err != nil {
            logger.fatalln(err.error())
            return
        }
    }
}

到目前为止，该服务使用 docker 运行，可以接收从 flutter 应用发送的数据，但应用无法接收服务器发回的数据。

以下是用于接收和发送消息的 flutter 代码片段：

final socket = await rawdatagramsocket.bind(internetaddress.anyipv4, 0).onerror((error, stacktrace) => throw error assocketexception);
              
final server = internetaddress("10.0.2.2");
final port = 8080;

final data = [
  deviceinfodata.deviceid,
  datetime.now().toutc().tostring()
];

datetime current = datetime.now();
late datetime responsetime;

socket.send(data.tostring().codeunits, server, port);

string serverout = "";

socket.listen((event) {
  final datagram = socket.receive();
  if (datagram != null) {
    // print("data sent to server: ${datagram.data}");
    string message = string.fromcharcodes(datagram.data);
    serverout = message.split("]").last;
    log(message);
    socket.close();
  } else {
    socket.close();
  }
});

udp服务的dockerfile是：

# Specifies a parent image
FROM golang:1.19.2-bullseye
 
# Creates an app directory to hold your app’s source code
WORKDIR /app
 
# Copies everything from your root directory into /app
COPY . .
 
# Installs Go dependencies
RUN go mod download
 
# Builds your app with optional configuration
RUN go build -o /udp-go
 
# Tells Docker which network port your container listens on
EXPOSE 8080
 
# Specifies the executable command that runs when the container starts
CMD [ "/udp-go" ]

为了运行它，我使用以下命令：

1. docker 构建 --rm -t udp-go:alpha .
2. docker run -d -p 8080:8080/udp --name go-udp udp-go:alpha

我使用/udp将容器中的udp端口映射到docker主机上的8080端口（https://docs.docker.com/config/containers/container-networking/）

但是，这仅允许我向服务发送数据。我知道这一点是因为检查 docker 日志显示该服务实际上正在接收数据。如果我要使用普通的旧 go run 而不是使用 docker 运行服务，则应用程序可以发送和接收消息。我该如何解决这个问题？

编辑：我尝试将 expose 8080\udp 添加到 dockerfile 而不仅仅是 expose 8080 但它仍然存在相同的错误。

正确答案

事实证明，这里的问题在于 flutter 代码本身。下面的代码片段是有效的代码片段。

final socket = await RawDatagramSocket.bind(InternetAddress.anyIPv4, 0).onError((error, stackTrace) => throw error asSocketException);
              
final server = InternetAddress("10.0.2.2");
final port = 8080;

final data = [
  deviceInfoData.deviceId,
  DateTime.now().toUtc().toString()
];

DateTime current = DateTime.now();
late DateTime responseTime;

socket.send(data.toString().codeUnits, server, port);

String serverOut = "";

socket.listen((event) {
  final datagram = socket.receive();
  if (datagram != null) {
    // print("Data sent to server: ${datagram.data}");
    String message = String.fromCharCodes(datagram.data);
    serverOut = message.split("]").last;
    log(message);
  } 
},
onDone: () => socket.close(),
);

使用 udp 代码时，我们必须关闭 ondone 上的套接字，而不是在监听时关闭套接字，因为 dart 可能尚未完全接收数据包。

好了，本文到此结束，带大家了解了《Flutter应用程序能够发送数据到Docker容器中的UDP服务器，但无法接收来自服务器的数据》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！