文件名称：stan.rb:Ruby NATS 流媒体客户端
文件大小：43KB
文件格式：ZIP
更新时间：2024-06-18 14:00:51
ruby nats nats-streaming Ruby
NATS 流 Ruby 客户端 用于平台的客户端。 入门 gem install nats-streaming 基本用法 require 'stan/client' sc = STAN :: Client . new # Customize connection to NATS opts = { servers : [ "nats://127.0.0.1:4222" ] } sc . connect ( "test-cluster" , "client-123" , nats : opts ) # Simple async subscriber sub = sc . subscribe ( "foo" , start_at : :first ) do | msg | puts "Received a message (seq= #{ msg . seq } ): #{ msg . d
【文件预览】：
stan.rb-master
----scripts()
--------install_server.sh(490B)
----lib()
--------stan()
----Gemfile(88B)
----nats-streaming.gemspec(1KB)
----spec()
--------client_subscription_spec.rb(23KB)
--------client_reconnection_spec.rb(6KB)
--------client_utils_spec.rb(1KB)
--------spec_helper.rb(4KB)
--------client_spec.rb(6KB)
--------.rspec(7B)
----GOVERNANCE.md(225B)
----Rakefile(1KB)
----examples()
--------sub_replay.rb(2KB)
--------queue_groups.rb(2KB)
--------sub_rate_limiting.rb(1020B)
--------advanced_sub.rb(1KB)
--------pub_rate_limiting.rb(1KB)
--------basic.rb(1KB)
--------advanced.rb(1KB)
--------durables.rb(1KB)
----benchmark()
--------pub_async_perf.rb(3KB)
--------pub_perf.rb(2KB)
--------sub_perf.rb(3KB)
----TODO.md(343B)
----.travis.yml(247B)
----LICENSE(11KB)
----README.md(10KB)
----pb()
--------protocol.proto(4KB)
----Gemfile.lock(703B)
----MAINTAINERS.md(151B)