swift - 在 ChannelInboundHandler (Swift-NIO) 中不支持 writeData

我正在尝试制作一个简单的回显 UDP 服务器，它发回所有以 UTF8 字符串为前缀的传入数据报。

在我试图达到这个目标的过程中，我成功地发回了传入的数据，但是当我尝试在这个数据前面加上字符串: "You sent: " 时，我收到了一个错误 writeDataUnsupported
这是我的代码:

我创建了一个名为 ChannelInboundHandler 的 Echo，它的作用是:对于每个传入的数据报，它发送字符串 "You sent: "，然后发送传入数据报的数据。

final class Echo: ChannelInboundHandler {
    typealias   InboundIn = ByteBuffer
    typealias OutboundOut = ByteBuffer

    var wroteResponse = false
    static let response = "You sent: ".data(using: .utf8)!

    func channelRead(ctx: ChannelHandlerContext, data: NIOAny) {
        if !wroteResponse {
            var buffer = ctx.channel.allocator.buffer(capacity: Echo.response.count)
            buffer.write(bytes: Echo.response)
            ctx.write(self.wrapOutboundOut(buffer), promise: nil)
            wroteResponse = true
        }
        ctx.write(data, promise: nil)
    }

    func channelReadComplete(ctx: ChannelHandlerContext) {
        ctx.flush()
        wroteResponse = false
    }
}

然后我创建了一个单线程事件循环组并为其分配了一个数据报 bootstrap 。然后我将 bootstrap 绑定(bind)到端口 4065。

let 🔂 = MultiThreadedEventLoopGroup(numThreads: 1)
let bootstrap = DatagramBootstrap(group: 🔂)
    .channelOption(ChannelOptions.socket(SocketOptionLevel(SOL_SOCKET), SO_REUSEADDR), value: 1)
    .channelInitializer { $0.pipeline.add(handler: Echo()) }
defer {
    try! 🔂.syncShutdownGracefully()
}


try bootstrap
    .bind(host: "127.0.0.1", port: 4065)
    .wait()
    .closeFuture
    .wait()

为什么我在尝试发送字符串时总是得到这个 writeDataUnsupported : "You sent: " ？

最佳答案

对于 DatagramChannel 您需要将 ByteBuffer 包装成 AddressEnvelope 。这也意味着您的 ChannelInboundHandler 应该对 AddressedEnvelope<ByteBuffer> 进行操作。

关于swift - 在 ChannelInboundHandler (Swift-NIO) 中不支持 writeData，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/49265262/