如何使用Crystal語言進行WebSocket通信

Crystal語言提供了一個名為HTTP::WebSocket的模塊，可用于WebSocket通信。以下是一個簡單的示例：

require "http/server"
require "http/websocket"

server = HTTP::WebSocket::Server.new do |socket|
  socket.on_message do |message|
    puts "Received message: #{message}"
    socket.send("Echo: #{message}")
  end
end

address = server.bind_tcp("0.0.0.0", 8080)
puts "Listening on http://#{address}"
server.listen

在這個示例中，我們創(chuàng)建了一個WebSocket服務(wù)器，它會接收客戶端發(fā)送的消息，并將其原樣返回給客戶端。通過調(diào)用socket.send方法發(fā)送消息給客戶端，通過socket.on_message監(jiān)聽客戶端發(fā)送的消息。

要連接到這個WebSocket服務(wù)器，您可以使用像websocketd這樣的工具，或者編寫一個簡單的WebSocket客戶端：

require "http/client"

client = HTTP::WebSocket::Client.new("ws://localhost:8080") do |socket|
  socket.on_message do |message|
    puts "Received message: #{message}"
  end

  socket.send("Hello, WebSocket!")
end

client.connect

在這個示例中，我們創(chuàng)建了一個WebSocket客戶端，它會連接到上面創(chuàng)建的WebSocket服務(wù)器，并發(fā)送一條消息。通過socket.send方法發(fā)送消息給服務(wù)器，通過socket.on_message監(jiān)聽服務(wù)器返回的消息。

這只是一個簡單的示例，您可以根據(jù)自己的需求進一步擴展WebSocket通信功能。Crystal語言提供了很好的支持，使WebSocket通信變得簡單而高效。