草庐IT

生产者

全部标签

php - 如何将生产者作为服务注入(inject) RabbitMQBundle 消费者?

我必须修改一个用Symfony和RabbitMQ开发的php系统作为一个队列系统。我没有直接使用RabbitMQ与PHP的绑定(bind),而是使用Symfony的RabbitMQBundle。我的问题是我不知道如何发布来自消费者的消息。是的,我知道,消费者旨在消费消息,而不是发布消息。但是我有一个多步骤的工作流,我需要在处理完一些以前的消息后发布新消息。Symfony的“魔力”让我无法发现一切是如何连接的。我一直在阅读有关服务的信息,但据我所知,“生产者”并未在任何地方声明为服务,在我的特殊情况下,我没有为每个人使用特定的类,而只是将名称绑定(bind)到RabbitMq交流。在我的

php - 开发与生产中的 Laravel "universal to"

我正在使用Laravel5.2应用程序。在我的开发和暂存环境中,我想使用“通用收件人”邮件配置选项describedinthedocs.开发环境中的通用to确保所有电子邮件都发送到该地址,而不是发送给真正的客户/客户/其他任何东西。不过,我不知道如何在生产中以不同方式指定它。在生产环境中,应该没有通用地址——电子邮件应该发送到真实地址。使用不同env()值的标准方法似乎不起作用。例如:config/mail.php:'to'=>['address'=>env('UNIVERSAL_TO',false)],开发.env:UNIVERSAL_TO=my-testing-address@so

java - JMSException InterruptedIOException - 生产者线程被中断

我收到JMS异常,队列似乎没有退出或没有完成任务。消息是异步的,大部分时间都可以正常工作,但有时会出现异常。似乎听众一直在听另一边,但在生产者那边得到了这个异常。javax.jms.JMSException:java.io.InterruptedIOExceptionatorg.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)atorg.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:

java - 使用 jpa2 和 hibernate 3.6.x 的生产实例的示例 persistence.xml

在生产场景中,将上述标志切换为false是有意义的。应该修改哪些其他标志,以便优化hibernate引擎以更快地访问MySQL数据库。 最佳答案 这取决于:)您可以设置缓存大小、获取深度(对于外部连接)、获取批量大小等等。您可能不想记录太多(show_sql=>设置为false,format_sql=>设置为false,use_sql_comments=>设置为false)。但实际上,这取决于您必须衡量。使用并正确配置连接池也很重要。再次重申:使用常识和衡量标准。希望这些链接对您有用:http://docs.jboss.org/hi

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

Producer-Consumerblogpost指出:"2)Producerdoesn'tneedtoknowaboutwhoisconsumerorhowmanyconsumersarethere.SameistruewithConsumer."我的问题是我有一组数据需要尽快从Web服务器获取到客户端。客户可以出现在中间计算。不同时间的多个客户端可以请求数据数组。一旦计算完成,它就会被缓存起来,然后就可以简单地读取它。Exmaple用例:在进行计算时,我想尽快为数组的每个数据提供服务。我不能使用BlockingQueue,因为如果第二个客户端开始请求数组,而第一个客户端已经在数组的

java - 生产者消费者线程间通信

在线程间通信方面遇到问题,并通过到处使用“虚拟消息”来“解决”它。这是一个坏主意吗?有哪些可能的解决方案?我遇到的示例问题。主线程启动一个线程来处理并将记录插入数据库。主线程读取一个可能很大的文件并将一个记录(对象)一个接一个地放入阻塞队列中。处理线程从队列中读取并工作。如何告诉“处理线程”停止?队列可以是空的,但工作没有完成,主线程现在也没有,当处理线程完成工作并且不能中断它时。所以处理线程做while(queue.size()>0||!Thread.currentThread().isInterrupted()){MyObjectobject=queue.poll(100,Time

java - 用于生产的好的断言类? Java 相当于 Groovy 的 PowerAssert?

我不喜欢javaassert关键字,因为它并不总是在生产代码中启用。我正在寻找一个很好的“ProductionAssert”类来使用,它总是运行注意到的断言。一个候选人是Guava'sPreconditions.它很不错,但有点受限(例如,没有assertEquals()、assertNull()、assertGreaterEquals())。一种替代方法是包括jUnit或其他测试框架……但我不愿意仅仅为了一个简单的断言类而依赖整个测试框架。如果我用Groovy编程,我会使用PowerAssert.Java有好的“ProductionAssert”类吗?附言-一种选择是最终检查类似Ja

Java:高性能消息传递(单一生产者/单一消费者)

我最初问过这个问题here,但我意识到我的问题不是关于while-true循环。我想知道的是,在Java中进行高性能异步消息传递的正确方法是什么?我正在尝试做什么......我有大约10,000个消费者,每个消费者都从他们的私有(private)队列中消费消息。我有一个线程一条一条地生成消息并将它们放入正确的消费者队列中。每个消费者无限循环,检查消息是否出现在其队列中并处理它。我相信这个术语是“单一生产者/单一消费者”,因为只有一个生产者,每个消费者只在他们的私有(private)队列上工作(多个消费者永远不会从同一个队列中读取数据)。Consumer.java内部:@Override

java - JRuby 准备好投入生产了吗?

我刚刚了解了JRuby,我喜欢在Rails上运行Ruby并能够调用Java库的想法。我想了解一些在JRuby中运行企业生产应用程序的经验。稳定性和性能是否可以接受?谢谢。 最佳答案 这是一篇来自一家公司的博文,该公司使用JRuby创建了一个跨平台、多线程、桌面模拟应用程序。我认为他们的成功表明JRuby已准备好用于企业生产应用程序。http://spin.atomicobject.com/2009/01/30/ruby-for-desktop-applications-yes-we-can

java - 限制开发人员访问 UAT 和生产环境但仍能完成任何工作的最佳实践

按照目前的情况,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visitthehelpcenter指导。关闭11年前。我在一家小公司工作,该公司正在经历从初创企业文化向更成熟的企业文化过渡的成长阵痛。过去,开发人员或多或少可以自由支配访问UAT环境,甚至可以自由访问生产环境。但是,在新方法下,开发人员只能访问开发和初始QA环境……并且无法访问UAT和生产环境。对这些环境的所有访问,从部署代码(在本例中为JavaWAR)到管理Java应用程序服务器,甚至审查日志和数据库,