等到值出现在哈希中

Question

最近，我接到了一项任务，要构建一个 REST API 请求，该请求负责将消息发送到 Kafka 的入站通道，然后等待出站通道的输出。一切顺利，直到我遇到与等待此特定消息相关的问题。

值得指出的是，成功到达后，消息将写入全局消息持有者，这只是一个 ruby 引擎盖下的哈希。下面是监控哈希的函数，直到后者被一些值填充。

def monitor_payment_hash(key)
 while @uuid.payment_create.get_message(key).nil?
   next
 end
 @uuid.payment_create.get_message(key)
end

这样实施是否合适？此时我应该尝试什么？
注意：Kafka 消费者在单独的线程中运行。

更新

我刚刚转到 ruby 文档，偶然发现了频道上一些有趣的部分。据我所知，通道是 rubytines 之间通信的最佳选择（只是 goroutines 的花哨名称，但在 ruby 生态系统中 :)）

Answer 1

我认为你需要timeout和一种强制停止轮询过程的方法，此外，你可能需要一个摘要以在将来改进。

class Poller
  def self.poll(key:, from_source:, options: {})
    start_time = Time.now
    catch(:stop_polling) do
      loop do
        message = from_source.get_message(key)
        if message.nil?
          wait_time = Time.now - start_time
          throw :stop_polling if wait_time > options[:timeout]
        else
          yield(message) if block_given?
          throw :stop_polling
        end
      end
    end
  end
end

def monitor_payment_hash(key)
  Poller.poll key: key, from_source: @uuid.payment_create, options: {timeout: 60} do |message|
    # write to the global message holders
    # or handle message by block
    yield(message) if block_given?
  end
end

您可能需要添加更多逻辑，例如超时重试、轮询键列表、日志...我建议您从这个来源学习如何构建长轮询：https://github.com/aws/aws-sdk-ruby/blob/version-3/gems/aws-sdk-sqs/lib/aws-sdk-sqs/queue_poller.rb

等到值出现在哈希中

Wait until value appears in the hash

ruby

ruby-kafka

更新