Внедрение функций чата в реальном времени с помощью Websocket в приложениях Ios

Оба подхода поддерживают безопасные соединения WebSocket (wss://) и могут использоваться взаимозаменяемо в зависимости от требований вашего проекта.

WebSocket против альтернатив для чата в реальном времени

Прежде чем перейти к реализации, полезно сравнить WebSocket с другими технологиями реального времени, используемыми в iOS:

• HTTP Long Polling — клиент отправляет запрос и сохраняет его открытым до тех пор, пока сервер не ответит новыми данными. Хотя он проще в реализации, он вводит более высокую задержку и накладные расходы сервера. Не рекомендуется для современных приложений чата.
• Server-Sent Events (SSE) — Однонаправленный от сервера к клиенту через стандартный HTTP. Полезен для прямых трансляций, но не подходит для отправки сообщений от клиента к серверу.
• Push-уведомления — отлично подходит для пробуждения приложения или доставки сообщений, когда оно находится в фоновом режиме, но не заменяет истинную двунаправленную связь в реальном времени.

WebSocket достигает правильного баланса: низкая задержка, полный дуплекс и поддержка iOS. Это фактический стандарт для чата в реальном времени в мобильных приложениях.

Предпосылки и настройка сервера

Ваше приложение iOS подключится к серверу WebSocket. В то время как реализация сервера выходит за рамки этой статьи, вам необходимо обеспечить поддержку WebSocket в бэкэнде. Если вы используете возможности Directus в реальном времени (доступные через его API WebSocket), вы можете быстро настроить чат. Directus предоставляет настраиваемую конечную точку WebSocket, которая может подписываться на изменения данных и обрабатывать сообщения, что делает его отличным выбором для прототипирования и функций производственного чата.

Для пользовательского сервера Node.js популярными вариантами являются ws (построенный на родной библиотеке «ws») или Socket.IO (который использует WebSocket в качестве транспорта с поддержкой резервного копирования). Какой бы бэкэнд вы ни выбрали, убедитесь, что он поддерживает безопасные wss://соединения и может обрабатывать параллельные соединения в масштабе.

Основные возможности сервера для планирования:

• Аутентификация и проверка токенов при первоначальном рукопожатии
• Маршрутизация сообщений (доставка конкретным получателям или комнатам)
• Хранение истории чата
• Обработка сбоев соединения и переподключение с сохранением сообщения

Если вы используете Directus, вы можете полагаться на его встроенные коллекции и подписки в реальном времени для реализации этих функций без написания пользовательского кода сервера. Эта статья будет предполагать пользовательский сервер WebSocket, который отправляет и получает сообщения JSON.

Настройка клиента WebSocket в iOS

Вариант 1: Использование URLSessionWebSocketTask (iOS 13+)

Этот собственный подход не требует сторонних зависимостей. Ниже приведена готовая к производству реализация, которая обрабатывает подключение, повторное подключение и сериализацию сообщений.

import Foundation

class ChatWebSocket {
 private var webSocketTask: URLSessionWebSocketTask?
 private var urlSession: URLSession = .shared
 private var serverURL: URL
 private var isConnected = false
 private var reconnectTimer: Timer?
 private var onMessage: ((ChatMessage) -> Void)?
 private var onConnectionState: ((Bool) -> Void)?

 init(serverURL: URL,
 onMessage: @escaping (ChatMessage) -> Void,
 onConnectionState: @escaping (Bool) -> Void) {
 self.serverURL = serverURL
 self.onMessage = onMessage
 self.onConnectionState = onConnectionState
 }

 func connect() {
 guard !isConnected else { return }
 var request = URLRequest(url: serverURL)
 // Add authentication token if required
 // request.setValue("Bearer \(authToken)", forHTTPHeaderField: "Authorization")
 webSocketTask = urlSession.webSocketTask(with: request)
 webSocketTask?.resume()
 isConnected = true
 onConnectionState?(true)
 listen()
 }

 private func listen() {
 webSocketTask?.receive { [weak self] result in
 guard let self = self else { return }
 switch result {
 case .failure(let error):
 print("Receive error: \(error.localizedDescription)")
 self.handleDisconnection()
 case .success(let message):
 switch message {
 case .string(let text):
 if let data = text.data(using: .utf8),
 let chatMessage = try? JSONDecoder().decode(ChatMessage.self, from: data) {
 self.onMessage?(chatMessage)
 }
 case .data(let data):
 if let chatMessage = try? JSONDecoder().decode(ChatMessage.self, from: data) {
 self.onMessage?(chatMessage)
 }
 @unknown default:
 break
 }
 // Continue listening for the next message
 self.listen()
 }
 }
 }

 func send(message: ChatMessage) {
 guard let data = try? JSONEncoder().encode(message),
 let text = String(data: data, encoding: .utf8) else { return }
 webSocketTask?.send(.string(text)) { error in
 if let error = error {
 print("Send error: \(error.localizedDescription)")
 }
 }
 }

 func disconnect() {
 reconnectTimer?.invalidate()
 webSocketTask?.cancel(with: .goingAway, reason: nil)
 isConnected = false
 onConnectionState?(false)
 }

 private func handleDisconnection() {
 webSocketTask = nil
 isConnected = false
 onConnectionState?(false)
 // Exponential backoff reconnection
 scheduleReconnect(delay: 2.0)
 }

 private func scheduleReconnect(delay: TimeInterval) {
 reconnectTimer?.invalidate()
 reconnectTimer = Timer.scheduledTimer(withTimeInterval: delay, repeats: false) { [weak self] _ in
 guard let self = self else { return }
 self.connect()
 // Next reconnection attempt with longer delay
 // In production, implement increasing backoff
 }
 }
}

Этот код включает автоматическое переподключение с фиксированной задержкой. В производстве вы захотите реализовать экспоненциальный обратный откат с дрожанием, чтобы избежать громовых проблем с стадом.

Вариант 2: использование Starscream

Starscream широко принят и обеспечивает дополнительный контроль. Установите его через Swift Package Manager или CocoaPods. Базовая настройка:

import Starscream

class StarscreamWebSocketManager {
 var socket: WebSocket!

 init(serverURL: URL) {
 var request = URLRequest(url: serverURL)
 request.timeoutInterval = 5
 socket = WebSocket(request: request)
 socket.delegate = self
 }

 func connect() {
 socket.connect()
 }

 func send(text: String) {
 socket.write(string: text)
 }

 func disconnect() {
 socket.disconnect()
 }
}

extension StarscreamWebSocketManager: WebSocketDelegate {
 func didReceive(event: WebSocketEvent, client: WebSocket) {
 switch event {
 case .connected(let headers):
 print("connected: \(headers)")
 case .disconnected(let reason, let code):
 print("disconnected: \(reason) with code: \(code)")
 case .text(let string):
 // Parse JSON message
 print("Received text: \(string)")
 case .binary(let data):
 print("Received data: \(data.count)")
 case .ping(_):
 break
 case .pong(_):
 break
 case .viabilityChanged(_):
 break
 case .reconnectSuggested(_):
 break
 case .cancelled:
 print("cancelled")
 case .error(let error):
 print("error: \(String(describing: error))")
 }
 }
}

Starscream автоматически обрабатывает пинг/понг и предоставляет события для изменения соединения. Его шаблон делегирования дает вам более детальный контроль над жизненным циклом соединения.

Внедрение функций Core Chat

Модель данных сообщений

Структурированная полезная нагрузка сообщения делает анализ и отображение надежными. Включите поля для:

• — уникальный идентификатор (UUID)
• — идентификатор пользователя
• — название дисплея
• — содержание сообщения
• - строка даты ISO 8601
• — например, «текст», «изображение», «система»
• — Дополнительный словарь для дополнительных данных (адреса файлов, реакции и т. д.)

Используйте Codable для простой сериализации:

struct ChatMessage: Codable {
 let id: String
 let senderId: String
 let senderName: String
 let text: String
 let timestamp: Date
 let type: MessageType
 let metadata: [String: String]?

 enum MessageType: String, Codable {
 case text, image, video, system
 }
}

Показатели печатания

Чтобы показать, когда пользователь печатает, отправьте легкие события:

// Client sends {"type": "typing", "userId": "123", "conversationId": "abc"}
// Server broadcasts to other participants

// Receive typing event:
struct TypingEvent: Codable {
 let type: String // "typing" or "stopTyping"
 let userId: String
 let conversationId: String
}

Переключите эти события, чтобы избежать наводнения (например, отправляйте каждые 300 мс при наборе текста, а также окончательное «остановите типографию», когда пользователь останавливается).

Читайте квитанции и подтверждения доставки

Сообщения, требующие подтверждения, могут включать в себя идентификатор ссылки.Когда клиент получает сообщение, он может отправить обратно подтверждение:

// Server includes message ID; client sends {"type": "ack", "messageId": "..."}
// Server can then update the sender's UI to show "Read" or "Delivered".

В iOS убедитесь, что вы отправляете подтверждения только тогда, когда сообщение фактически отображается пользователю (например, когда ячейка становится видимой).

Защита WebSocket Connections

Безопасность должна быть обеспечена с самого начала. Вот основные меры:

• Всегда используйте WSS — WebSocket по TLS шифрует все данные при передаче.
• Удостоверить соединение — Включить токен (например, JWT) в начальные заголовки рукопожатия HTTP или в качестве параметра запроса. Проверить его на сервере, прежде чем разрешить соединение.
• Проверка сообщений — Сервер должен проверять личность отправителя каждого входящего сообщения. Никогда не доверяйте отправителю, предоставленному клиентом, без приведения в исполнение на стороне сервера.
• Ограничение ставок — Предотвращение злоупотреблений путём ограничения количества сообщений в секунду от одного клиента.Использовать токен-букет или алгоритмы протекания ведра на сервере.
• Санифицировать ввод — Побег или дезинфицировать текстовый контент, чтобы предотвратить XSS при отображении сообщений в WebView или собственном пользовательском интерфейсе.

Для iOS ATS (App Transport Security) Apple обеспечивает соблюдение TLS по умолчанию. Если вы используете (небезопасный), вы должны добавить исключение в Info.plist, но вы должны избегать этого в производстве.

Лучшие практики для приложений для производственных чатов

Стратегия подключения с экспоненциальным отступлением

Неизбежны перебои в работе сети. Надежная логика переподключения с экспоненциальным выключением и случайным дрожанием предотвращает перегрузку сервера:

private func scheduleReconnect() {
 let baseDelay: TimeInterval = 1.0
 let maxDelay: TimeInterval = 30.0
 reconnectAttempt += 1
 let delay = min(pow(2.0, Double(reconnectAttempt)) * baseDelay, maxDelay)
 // Add jitter: ±50% of delay
 let jitter = Double.random(in: -delay * 0.5...delay * 0.5)
 DispatchQueue.main.asyncAfter(deadline: .now() + delay + jitter) { [weak self] in
 self?.connect()
 }
}

[14] При условии, что они будут успешно восстановлены.

Обработка справочного состояния и push-уведомлений

Когда приложение войдет в фоновый режим, соединение WebSocket может быть приостановлено iOS. Для поддержания доставки в режиме реального времени объедините WebSocket с push-уведомлениями:

• Когда приложение переходит в фоновый режим, отправьте на сервер временную метку «lastOnline».
• Сервер отправляет push-уведомления через APN для входящих сообщений, когда пользователь находится в автономном режиме.
• После возвращения на передний план, переподключите WebSocket и возьмите пропущенные сообщения с сервера.

Используйте и для управления соединением.

Оффлайн-посылка

Если WebSocket отключен, выходящие сообщения очередей локально и отправляйте их после повторного подключения. Используйте локальную базу данных (например, основные данные или область), чтобы сохранить очередь во время запуска приложений.

Заказ сообщений и дедупликация

Сообщения могут выходить из строя из-за сетевых условий. Используйте порядковый номер или сортировку на основе метки времени. На стороне клиента, дублируйте по идентификатору сообщения, чтобы избежать показа дубликатов после повторного подключения.

UI-отзывчивость

Все WebSocket I/O работает на фоновых потоках. Всегда отправляйте обновления пользовательского интерфейса на основной поток:

DispatchQueue.main.async { [weak self] in
 self?.updateChatUI(with: chatMessage)
}

Для этого следует использовать комбинированные или асинхронные/ожидаемые для более чистых параллелей. может быть обернут в для параллелей Swift.

Тестирование и отладка WebSocket в iOS

Симулятор и тестирование устройств

Проверка на симуляторах и реальных устройствах.У симуляторов меньше сетевых ограничений, поэтому вы можете пропустить такие проблемы, как прерывистое подключение или фоновая подвеска.

Инструменты для отладки

• Paw или Postman — Может имитировать соединения WebSocket для тестирования на стороне сервера.
• Чарльз Прокси / Проксимен — Проверяйте фреймы WebSocket (текстовые и двоичные) в пути.
• Кондиционер сетевых ссылок — моделирование неблагоприятных условий сети (задержка, потеря пакетов).
• Консоль и инструменты Xcode — события подключения к логину и использование памяти монитора.

Общие подводные камни

• Забыв позвонить в задачу WebSocket — соединение никогда не установится.
• Не переслушивая после получения сообщения (FLT: 1) - Каждый звонок в [FLT: 21] потребляет одно входящее сообщение. Вы должны позвонить ему снова (см. рекурсивный шаблон [FLT: 22] выше).
• Утечки памяти — Сильные опорные циклы в замыканиях делегатов. Всегда используйте или .
• Блокировка основной нити с помощью тяжелого JSON-разбора — парсовые сообщения на задней очереди.

Подключение к Directus для бэкэнда в реальном времени

Directus предоставляет встроенный интерфейс WebSocket, который упрощает разработку бэкэнда. С Directus вы можете:

• Подписывайтесь на изменения в любой коллекции (например, в коллекции ) и получайте обновления в режиме реального времени.
• Отправляйте пользовательские события, которые другие клиенты могут слушать.
• Обработка аутентификации через систему токенов Directus.

Интеграция Directus WebSocket в iOS:

// Example using URLSessionWebSocketTask
guard let url = URL(string: "wss://your-directus-instance.com/websocket") else { return }
let task = URLSession.shared.webSocketTask(with: url)
task.resume()

// Subscribe to a collection
let subscribeMessage = """
{"type":"subscribe","collection":"messages","query":{"filter":{"status":{"_eq":"published"}}}}
""".data(using: .utf8)!
task.send(.data(subscribeMessage)) { error in
 if let error = error { print(error) }
}

Directus будет продвигать изменения по мере их возникновения. Это сводит пользовательскую логику сервера к нулю. Более подробную информацию см. в документации Directus WebSocket.

Для дальнейшего чтения обратитесь к документации Apple по URLSessionWebSocketTask и Репозиторию Starscream GitHub. Также изучите RFC 6455 для деталей протокола WebSocket.