루비 NATS 간행

Question

루비에서 NATS를 배우고 있으며 표준 입력란에서 간단한 "cat"을 만들고 싶습니다. 내가 모든 라인을 얻었고 루프가 종료되지 않거나 아무것도 보내지지 않습니다.

!/usr/bin/env ruby 

require "nats/client" 

queue = ARGV.shift 

NATS.start do 
    STDIN.each_line do |line| 
    puts "will send: #{line}" 
    NATS.publish(queue, line) 
    end 

    NATS.stop 
end 

puts "... #{__LINE__}" 
exit 0 

그리고 실행 : 그것은 정확하게 보낼 시도 할 것이다 각 라인을 보여주고, 프로그램이 종료하지만

NATS.stop이 활성화

# cat cat.rb | ./cat.rb myqueue 

, 아무것도, 큐에 최대 보여줍니다 :

# cat cat.rb | ./cat.rb myqueue 
will send: #!/usr/bin/env ruby 
will send: 
will send: require "nats/client" 
will send: 
will send: queue = ARGV.shift 
will send: 
will send: NATS.start do 
will send: STDIN.each_line do |line| 
will send:  puts "will send: #{line}" 
will send:  NATS.publish(queue, line) 
will send: end 
will send: 
will send: NATS.stop 
will send: end 
will send: 
will send: puts "... #{__LINE__}" 
will send: exit 0 
will send: 
... 16 
# 

그리고 NATS.stop와

는 모든 라인이 큐에 전송, 주석,하지만 프로그램이 종료되지 않습니다

을

# cat cat.rb | ./cat.rb myqueue 
will send: #!/usr/bin/env ruby 
will send: 
will send: require "nats/client" 
will send: 
will send: queue = ARGV.shift 
will send: 
will send: NATS.start do 
will send: STDIN.each_line do |line| 
will send:  puts "will send: #{line}" 
will send:  NATS.publish(queue, line) 
will send: end 
will send: 
will send: # NATS.stop 
will send: end 
will send: 
will send: puts "... #{__LINE__}" 
will send: exit 0 
will send: 
<and program sits here> 

무엇이 누락 되었습니까? Ruby에서 멀티 스레딩 문제를 포함하지 않는 메시지를 보내는 것이 더 쉽지 않을까요?

Answer 1

귀하의 예를 들어 당신과 같이 일을하고 그것을 시도를 제공 할 수 있습니다 : 그것은 보류중인 모든 이벤트가 연결을 닫기 전에 처리됩니다 확인해야하기 때문에

따라서는, NATS.stop 전에 NATS.flush이 솔루션을 호출하는 것 모든 회선이 게시되고 이벤트 루프를 중지하기 전에 서버로 플러시됩니다.

require 'nats/client' 

$stdout.sync = true 

NATS.start(servers: ["nats://127.0.0.1:4222"]) do |nats| 
    STDIN.read.each_line do |line| 
    nats.publish("hello", line) 
    end 
    nats.flush do 
    nats.close 
    end 
end 

Answer 2

라이브러리에 대한 코드를 보면 NATS.stop은 아직 처리가 남아 있는지 확인하지 않고 즉시 연결이 끊어지는 매우 공격적인 것으로 보입니다.

NATS.start do 
    ...do your messaging... 

    NATS.flush # Ensure processing of pending messages  
    NATS.stop # Immidiate exit 
end