You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何复用SocketIO的emit方法并绑定到SwiftUI按钮动作?

问题解决思路与修改方案

核心问题根源:你当前将socket定义为init方法内部的局部变量,作用域仅限制在init范围内,类的其他成员方法自然无法访问到该变量,这就是你触发「无法找到对应作用域」报错的根本原因。

修改步骤

  1. 将socket提升为Service类的全局存储属性,让类内所有方法都可以访问
  2. 连接事件、消息接收事件的监听仅需在init中注册一次即可,不要每次发送消息时重复注册监听,避免触发重复回调
  3. 移除主线程中的sleep调用,避免阻塞UI渲染,如有延迟需求请使用DispatchQueue.asyncAfter实现

修改后完整可运行代码

import SwiftUI
import SocketIO
import zlib

final class Service: ObservableObject {
    @Published var manager = SocketManager(socketURL: URL(string:"ws://localhost:4044")!, config:[.log(true), .compress])
    @Published var messages = [String]()
    // 新增socket类属性,全类可访问
    private let socket: SocketIOClient

    init(){
        // 给类属性赋值
        self.socket = manager.defaultSocket

        // 连接监听仅注册一次
        socket.on(clientEvent: .connect){ (data, ack) in
            print("Connected")
            DispatchQueue.main.async{
                self.socket.emit("NodeJS Server Port","Hi server111")
                self.socket.emit("NodeJS Server Port","testing")
                // 不要在主线程用sleep,会卡UI,需要延迟请用asyncAfter
                // sleep(UInt32(0.3))
            }
        }
        
        // 消息接收监听仅注册一次
        socket.on("iOS Client Port"){ [weak self] (data, ack) in
            guard let self = self else { return }
            if let data = data[0] as? [String: String],
               let rawMessage = data["msg"] {
                DispatchQueue.main.async{
                    self.messages.append(rawMessage)
                    print(rawMessage)
                    self.socket.emit("NodeJS Server Port","msg received")
                }
            }
        }
        socket.connect()
    }
    
    // 按钮调用的发送方法,直接调用socket.emit即可
    func sendMsgFunc(){
        // 可先判断socket是否处于连接状态,避免无效调用
        guard socket.status == .connected else {
            print("socket未连接")
            return
        }
        socket.emit("NodeJS Server Port","点击按钮发送的消息")
        // 你可以自定义发送的内容,比如绑定输入框的文本
        // socket.emit("NodeJS Server Port", textFieldContent)
    }
}

struct ContentView: View {
    @ObservedObject var service = Service()
    @State var textFieldText: String = ""

    var body: some View {
        VStack{
            Text("Received messages")
                .font(.largeTitle)
            
            Button("Click", action: service.sendMsgFunc)
            Button("Connect .2"){
                print("hello .2")
            }

            ForEach(service.messages, id: \.self) { msg in
                Text(msg).padding()
            }
        }
    }
    
    struct ContentView_Previews: PreviewProvider {
        static var previews: some View {
            ContentView()
        }
    }
}

内容的提问来源于stack exchange,提问作者michaeldylann

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.09.26 11:54:08