使用EventMachine设置无限循环以生成随机数据

Question

我试图设置一个自动压力测试，并将随机生成的数据输入Redis，然后让消费者（作为从Redis读取的另一个组件）处理随机数据。

为了模拟随机生成的数据尽可能接近真实世界的计时，我决定将其放入一个无限循环中，并使用EventMachine来处理同步。我不确定我在用EventMachine做什么，但我听说它比不断生成新线程并阻塞主进程要好得多。我这样做对吗？

EventMachine.synchrony do

  @redis = EM::Hiredis.connect

  # hit Control + C to stop
  Signal.trap("INT")  { EventMachine.stop }
  Signal.trap("TERM") { EventMachine.stop }

  trip_id = 0
  loop do
    longitude, latitude = [0.0, 0.0]
    for i in 0..100
      # now loop
      longitude, latitude = random_coordinates

      sleep 0.05 # sleep a bit to simulate the real world 
    end

    puts "this trip #{trip_id} | #{longitude} : #{latitude}"
    trip_id += 1

    redis.set('trip_id', trip_id)
  end
end

编辑1

所以我最终用一个线程池来完成它

require "thread/pool"
require "json"
require "redis"

require 'thread_safe'

def publish_on_redis(hash)
  @redis ||= Redis.new
  @redis.publish("trips", hash.to_json)
end

# Using thread-safe data structure
@trip_id_list = ThreadSafe::Array.new()
TRIP.times {|n| @trip_id_list[n] = n}
@trip_id_list.shuffle!

pool = Thread.pool(TRIP)
loop do
  @trip_id_list.each do |trip_id|
    pool.process {
      longitude, latitude = [0.0, 0.0]
      # Everything has to be UTC timestamp, everyone is on the same timezone
      start = Time.now.utc
      while((Time.now.utc - start) < @total_duration)
        longitude, latitude = random_coordinates_radius
        publish_on_redis({:id => trip_id, :time => Time.now, :longitude => longitude, :latitude => latitude})
        sleep 1 # sleep at each run some amount of times
      end
      publish_on_redis({:id => trip_id, :time => Time.now, :longitude => longitude, :latitude => latitude})
      @trip_id_list.delete(trip_id)
    }
  end

  break # will have to exit the infinite loop
end
pool.shutdown

Answer 1

像您在这里所做的那样生成随机事件似乎是正确的。

然而，您根本没有强调redis，您只是在做一个简单的“集合”，如果密钥存在，它将用新数据覆盖密钥。

我建议使用一个填充了大量数据的管道，您可以在测试块中等待它的执行（睡眠）。

将sleep语句移到数据准备代码之外。

希望这有帮助，TW