如何使用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

在这个示例中，我们创建了一个WebSocket服务器，它会接收客户端发送的消息，并将其原样返回给客户端。通过调用socket.send方法发送消息给客户端，通过socket.on_message监听客户端发送的消息。

要连接到这个WebSocket服务器，您可以使用像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

在这个示例中，我们创建了一个WebSocket客户端，它会连接到上面创建的WebSocket服务器，并发送一条消息。通过socket.send方法发送消息给服务器，通过socket.on_message监听服务器返回的消息。

这只是一个简单的示例，您可以根据自己的需求进一步扩展WebSocket通信功能。Crystal语言提供了很好的支持，使WebSocket通信变得简单而高效。