草庐IT

java - 网络服务器流式传输数据数组中的消费者-生产者问题

coder 2024-04-02 原文

Producer-Consumer blog post指出:

"2) Producer doesn't need to know about who is consumer or how many consumers are there. Same is true with Consumer."

我的问题 是我有一组数据需要尽快从 Web 服务器获取到客户端。客户可以出现在中间计算。不同时间的多个客户端可以请求数据数组。一旦计算完成，它就会被缓存起来，然后就可以简单地读取它。

Exmaple 用例:在进行计算时，我想尽快为数组的每个数据提供服务。我不能使用 BlockingQueue，因为如果第二个客户端开始请求数组，而第一个客户端已经在数组的前半部分使用了 .take()。然后第二个客户端漏掉了一半的数据!我需要一个 BlockingQueue，您不必在其中使用 ()，但您可以只读取 (int index)。

解决方案？ 我的阵列上有大量写入，所以我不想使用 CopyOnWriteArrayList？ Vector 类应该工作但效率低下？ 是否最好使用像 this 这样的 ThreadSafeList？并添加一个 waitForElement() 函数？我只是不想重新发明轮子，我更喜欢经过人群测试的多线程问题解决方案......

最佳答案

据我了解，您需要将数据广播 到订阅者/客户端。 以下是我所知道的一些方法。

  • 纯 Java 解决方案，每个客户端都有一个 BlockingQueue，每次广播一条消息时，您都会将其放入每个队列。

    for(BlockingQueue client: clients){
  client.put(msg);
}

  • RxJava提供一个 reactive approach .客户将成为订阅者，每当您发出消息时，订阅者都会收到通知，他们可以选择取消订阅

    Observable<String> observable = Observable.create(sub->{
    String[] msgs = {"msg1","msg2","msg3"};
    for (String msg : msgs) {
        if(!sub.isUnsubscribed()){
            sub.onNext(msg);
        }
    }
    if (!sub.isUnsubscribed()) { // completes
        sub.onCompleted();
    }

});

    现在多个订阅者可以选择接收消息。

    observable.subscribe(System.out::println);
observable.subscribe(System.out::println);

    Observables 有点功能，他们可以选择他们需要的。

    observable.filter(msg-> msg.equals("msg2")).map(String::length)
   .subscribe(msgLength->{
    System.out.println(msgLength); // or do something useful
});

  • Akka提供 broadcast routers

关于java - 网络服务器流式传输数据数组中的消费者-生产者问题，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33311378/

流式网络服务code订阅者noreferrerjavaconcurrencyproducer-consumerjava.util.concurrent

有关java - 网络服务器流式传输数据数组中的消费者-生产者问题的更多相关文章

  1. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我

  2. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  3. ruby - 在 64 位 Snow Leopard 上使用 rvm、postgres 9.0、ruby 1.9.2-p136 安装 pg gem 时出现问题 - 2

    我想为Heroku构建一个Rails3应用程序。他们使用Postgres作为他们的数据库，所以我通过MacPorts安装了postgres9.0。现在我需要一个postgresgem并且共识是出于性能原因你想要pggem。但是我对我得到的错误感到非常困惑当我尝试在rvm下通过geminstall安装pg时。我已经非常明确地指定了所有postgres目录的位置可以找到但仍然无法完成安装:$envARCHFLAGS='-archx86_64'geminstallpg--\--with-pg-config=/opt/local/var/db/postgresql90/defaultdb/po

  4. ruby - 通过 rvm 升级 ruby​​gems 的问题 - 2

    尝试通过RVM将RubyGems升级到版本1.8.10并出现此错误:$rvmrubygemslatestRemovingoldRubygemsfiles...Installingrubygems-1.8.10forruby-1.9.2-p180...ERROR:Errorrunning'GEM_PATH="/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/ruby-1.9.2-p180@global:/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/rub

  5. ruby - 通过 RVM (OSX Mountain Lion) 安装 Ruby 2.0.0-p247 时遇到问题 - 2

    我的最终目标是安装当前版本的RubyonRails。我在OSXMountainLion上运行。到目前为止，这是我的过程:已安装的RVM$\curl-Lhttps://get.rvm.io|bash-sstable检查已知(我假设已批准)安装$rvmlistknown我看到当前的稳定版本可用[ruby-]2.0.0[-p247]输入命令安装$rvminstall2.0.0-p247注意:我也试过这些安装命令$rvminstallruby-2.0.0-p247$rvminstallruby=2.0.0-p247我很快就无处可去了。结果:$rvminstall2.0.0-p247Search

  6. ruby - Fast-stemmer 安装问题 - 2

    由于fast-stemmer的问题，我很难安装我想要的任何ruby​​gem。我把我得到的错误放在下面。Buildingnativeextensions.Thiscouldtakeawhile...ERROR:Errorinstallingfast-stemmer:ERROR:Failedtobuildgemnativeextension./System/Library/Frameworks/Ruby.framework/Versions/2.0/usr/bin/rubyextconf.rbcreatingMakefilemake"DESTDIR="cleanmake"DESTDIR=

  7. java - 等价于 Java 中的 Ruby Hash - 2

    我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/

  8. ruby-on-rails - 启动 Rails 服务器时 ImageMagick 的警告 - 2

    最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru

  9. ruby-on-rails - s3_direct_upload 在生产服务器中不工作 - 2

    在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo

  10. ruby - 安装 Ruby 时遇到问题(无法下载资源 "readline--patch") - 2

    当我尝试安装Ruby时遇到此错误。我试过查看this和this但无济于事➜~brewinstallrubyWarning:YouareusingOSX10.12.Wedonotprovidesupportforthispre-releaseversion.Youmayencounterbuildfailuresorotherbreakages.Pleasecreatepull-requestsinsteadoffilingissues.==>Installingdependenciesforruby:readline,libyaml,makedepend==>Installingrub

随机推荐