学习Vapor开发天气警报展示网站：BlueSocket连TCP流后下一步咨询

Hey there! Let's walk through the next steps you need to take now that you've got your BlueSocket connection set up to that weather alert TCP stream. Handling continuous streaming data can feel tricky at first, but breaking it down into small tasks makes it manageable:

TCP streams send data in chunks, so you need a persistent loop to keep reading as new data arrives. BlueSocket's read() method will pull available bytes, but you'll want to wrap this in a loop that runs while the connection is active. Don't forget to handle errors (like dropped connections) gracefully:

func startStreamReading(socket: Socket) {
    var dataBuffer = Data()
    while socket.isConnected {
        do {
            let bytesRead = try socket.read(into: &dataBuffer)
            if bytesRead > 0 {
                // Pass the accumulated buffer to processing logic
                processIncomingData(buffer: &dataBuffer)
            }
        } catch {
            print("Stream read error: \(error.localizedDescription)")
            break // Exit loop and trigger reconnection later
        }
    }
}

Chances are, a single read() call might give you part of an alert, or multiple alerts stuck together. You'll need to split the buffer using the stream's message delimiter (Pelmorex's NAAD stream typically uses specific separators like \n\n or a custom marker for alert boundaries). Here's how to extract full alerts while keeping partial data in the buffer:

func processIncomingData(buffer: inout Data) {
    let alertSeparator = Data("\n\n".utf8) // Adjust to match the actual stream separator
    
    // Loop until no full alerts are left in the buffer
    while let separatorRange = buffer.range(of: alertSeparator) {
        // Extract the full alert data
        let fullAlertData = buffer[..<separatorRange.lowerBound]
        // Convert to string and parse
        if let alertString = String(data: fullAlertData, encoding: .utf8) {
            parseWeatherAlert(alertString: alertString)
        }
        // Remove the processed alert and separator from the buffer
        buffer.removeSubrange(...separatorRange.upperBound)
    }
}

Next, you need to turn the raw alert string into a structured Swift model that Vapor can work with. First, confirm the NAAD stream's format (it's often XML or JSON). For example, if it's JSON, use Vapor's built-in Codable support:

// Define a model matching the alert structure
struct WeatherAlert: Codable {
    let alertID: String
    let title: String
    let description: String
    let issuedTimestamp: Date
    let region: String
    // Add other fields based on the actual alert format
}

func parseWeatherAlert(alertString: String) {
    guard let alertData = alertString.data(using: .utf8) else {
        print("Failed to convert alert string to data")
        return
    }
    
    do {
        let decoder = JSONDecoder()
        // Adjust date decoding strategy to match the stream's date format
        decoder.dateDecodingStrategy = .iso8601
        let alert = try decoder.decode(WeatherAlert.self, from: alertData)
        
        // Now pass the parsed alert to your Vapor logic
        handleParsedAlert(alert: alert)
    } catch {
        print("Alert parsing error: \(error)")
    }
}

Now that you have parsed alerts, you need to make them available to your website:

• Store alerts in a database: Use Vapor's Fluent ORM to create a database table for alerts. Add logic to avoid duplicate alerts (check by alertID or timestamp).
• Expose API endpoints: Create a route like GET /api/weather-alerts that fetches stored alerts and returns them as JSON to your frontend.
• Real-time updates (optional): Use Vapor's WebSocket support to push new alerts to connected frontend clients instantly, instead of forcing them to refresh.

TCP connections can drop unexpectedly (network issues, server restarts). Add a retry mechanism to automatically reconnect if the stream goes down:

func connectToAlertStream() {
    do {
        let socket = try Socket.create()
        try socket.connect(to: "streaming1.naad-adna.pelmorex.com", port: 8080)
        print("Successfully connected to weather alert stream")
        startStreamReading(socket: socket)
    } catch {
        print("Connection failed: \(error.localizedDescription)")
        // Retry after 3 seconds (adjust delay as needed)
        DispatchQueue.global().asyncAfter(deadline: .now() + 3) {
            connectToAlertStream()
        }
    }
}

• Test with raw data first: Before parsing, print the raw string you get from the stream to confirm the exact format and separator. This will save you hours of debugging parsing errors.
• Offload heavy work: Don't block Vapor's main event loop with parsing or database writes. Use DispatchQueue.global().async to handle these tasks in the background.
• Check usage terms: Make sure you're complying with Pelmorex's terms of service for using their NAAD stream.

内容的提问来源于stack exchange，提问作者maldahleh