iphone中的套接字编程示例

import Foundation

// 创建套接字
let clientSocket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_STREAM, IPPROTO_TCP, 0, nil, nil)

// 设置服务器地址
var serverAddress = sockaddr_in()
serverAddress.sin_len = __uint8_t(MemoryLayout<sockaddr_in>.size)
serverAddress.sin_family = sa_family_t(AF_INET)
serverAddress.sin_port = htons(1234) // 服务器端口号
serverAddress.sin_addr.s_addr = inet_addr("服务器IP地址")

// 连接服务器
let connectResult = withUnsafePointer(to: &serverAddress) {
    $0.withMemoryRebound(to: sockaddr.self, capacity: 1) {
        CFSocketConnectToAddress(clientSocket, $0, CFTimeInterval(10))
    }
}

if connectResult == kCFSocketSuccess {
    // 连接成功，发送数据
    let message = "Hello, Server!"
    let data = message.data(using: .utf8)!
    let bytesWritten = CFSocketSendData(clientSocket, nil, data as CFData, CFTimeInterval(10))
    
    if bytesWritten > 0 {
        print("Data sent successfully!")
    } else {
        print("Failed to send data.")
    }
} else {
    print("Failed to connect to the server.")
}

// 关闭套接字
CFSocketInvalidate(clientSocket)

import Foundation

// 创建套接字
let serverSocket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_STREAM, IPPROTO_TCP, 0, nil, nil)

// 设置本地地址
var localAddress = sockaddr_in()
localAddress.sin_len = __uint8_t(MemoryLayout<sockaddr_in>.size)
localAddress.sin_family = sa_family_t(AF_INET)
localAddress.sin_port = htons(1234) // 本地监听端口号
localAddress.sin_addr.s_addr = INADDR_ANY

// 绑定本地地址
let bindResult = withUnsafePointer(to: &localAddress) {
    $0.withMemoryRebound(to: sockaddr.self, capacity: 1) {
        CFSocketSetAddress(serverSocket, $0)
    }
}

if bindResult == kCFSocketSuccess {
    // 监听连接
    CFSocketSetSocketFlags(serverSocket, kCFSocketAcceptCallBack)
    CFRunLoopAddSource(CFRunLoopGetCurrent(), CFSocketCreateRunLoopSource(kCFAllocatorDefault, serverSocket, 0), .defaultMode)
    print("Server started. Waiting for connections...")
} else {
    print("Failed to bind the local address.")
}

// 处理连接回调
let acceptCallback: CFSocketCallBack = { (socket, type, address, data, info) in
    let clientSocket = UnsafeMutableRawPointer(mutating: data!.assumingMemoryBound(to: CFSocketNativeHandle.self)).pointee
    
    // 接收数据
    var buffer = [UInt8](repeating: 0, count: 1024)
    let bytesRead = recv(clientSocket, &buffer, buffer.count, 0)
    
    if bytesRead > 0 {
        let receivedData = Data(bytes: buffer, count: bytesRead)
        let receivedMessage = String(data: receivedData, encoding: .utf8)!
        print("Received data from client: \(receivedMessage)")
    } else {
        print("Failed to receive data from client.")
    }
    
    // 关闭客户端套接字
    close(clientSocket)
}

// 设置连接回调
let socketContext = CFSocketContext(version: 0, info: nil, retain: nil, release: nil, copyDescription: nil)
CFSocketSetSocketCallBack(serverSocket, acceptCallback, &socketContext)

// 运行主循环
CFRunLoopRun()