Ruby UDP通信如何处理并发

在Ruby中处理UDP通信并发可以通过使用多线程或异步IO来实现。这里，我们将介绍如何使用Thread和IO.select来实现并发UDP通信。

使用Thread

require 'socket'

def udp_server(port)
  server = UDPServer.new(port)
  server.bind('0.0.0.0')

  loop do
    message, _ = server.recvfrom(1024)
    puts "Received message: #{message}"

    # 创建一个新线程来处理接收到的消息
    Thread.new do
      handle_message(message)
    end
  end
end

def handle_message(message)
  # 处理消息的逻辑
  puts "Handling message: #{message}"
end

# 启动服务器
udp_server(12345)

使用IO.select

require 'socket'

def udp_server(port)
  server = UDPServer.new(port)
  server.bind('0.0.0.0')

  inputs = [server]
  outputs = []
  sockets = {}

  loop do
    readable, writable, exceptional = IO.select(inputs, outputs, sockets)

    readable.each do |sock|
      if sock == server
        message, _ = sock.recvfrom(1024)
        puts "Received message: #{message}"

        # 将服务器套接字添加到sockets字典中
        sockets[sock] = true

        # 创建一个新线程来处理接收到的消息
        Thread.new do
          handle_message(message)
        end
      else
        handle_client(sock, message)
      end
    end

    writable.each do |sock|
      # 处理可写套接字
    end

    exceptional.each do |sock|
      # 处理异常套接字
      puts "Socket exception: #{sock}"
      sockets.delete(sock)
    end
  end
end

def handle_client(sock, message)
  # 处理客户端消息的逻辑
  puts "Handling client message: #{message}"
  sock.send("Response from server".encode)
end

def handle_message(message)
  # 处理消息的逻辑
  puts "Handling message: #{message}"
end

# 启动服务器
udp_server(12345)

这两种方法都可以实现Ruby中的UDP通信并发。使用Thread方法会为每个接收到的消息创建一个新线程，而使用IO.select方法则允许你在单个线程中处理多个套接字。根据你的需求和场景，可以选择合适的方法来处理UDP通信并发。