标签: message-queue

有谁知道一个可以监视beanstalkd队列的应用程序？我正在寻找显示管和工作统计数据的东西,并允许您检查细节.

我对语言/平台并不是很挑剔,只是想在我自己编写之前知道是否有某些东西.

我有春季罐子,spring-3.2.0.RC1.jar并尝试Apache ActiveMQ helloWorld从这里给出的教程实现程序.xml配置文件是:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:jms="http://www.springframework.org/schema/jms"
    xmlns:p="http://www.springframework.org/schema/p" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://www.springframework.org/schema/beans"
    xsi:schemalocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/jms 
    http://www.springframework.org/schema/jms/spring-jms.xsd">

    <bean class="org.apache.activemq.command.ActiveMQQueue" id="destination">
        <constructor-arg value="TEST.Q1"></constructor-arg>
    </bean>

    <bean class="org.apache.activemq.ActiveMQConnectionFactory" id="connectionFactory"
        p:brokerurl="tcp://localhost:8161"></bean>

    <bean class="com.jms.helloworld.listner.MessageListenerImpl" id="simpleMessageListener">
        <bean
            class="org.springframework.jms.listener.DefaultMessageListenerContainer"
            id="jmsContainer">
            <property name="connectionFactory" ref="connectionFactory"></property>
            <property name="destination" ref="destination"></property>
            <property name="messageListener" ref="simpleMessageListener"></property>
        </bean>
    </bean>
</beans>    

主要:

public static void main(String[] args) throws JMSException {
        System.out.println("LISTNER STARTED");
        ApplicationContext context =  new FileSystemXmlApplicationContext("src/com/jms/helloworld/config/JMSConfig.xml");
    }

**Exception on console**


LISTNER STARTED
log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment). …

我有一个JMS客户端,它生成消息并通过JMS队列发送给其唯一的消费者.

我想要的是不止一个消费者获得这些消息.我想到的第一件事就是将队列转换为主题,因此当前和新的消费者可以订阅并获得传递给所有消息的相同消息.

这显然涉及在生产者和消费者方面修改当前客户端代码.

我还想看看其他选项,比如创建第二个队列,这样我就不必修改现有的消费者了.我相信这种方法有一些优点(如果我错了,请纠正我)平衡两个不同队列之间的负载而不是一个,这可能会对性能产生积极影响.

我想就你可能会看到的这些选项和缺点/专业人士提出建议.任何反馈都非常感谢.

我正在使用Kafka的高级消费者.因为我正在使用Kafka作为我的应用程序的"事务队列",所以我需要确保我不会错过或重读任何消息.我有两个问题:

1. 如何将偏移量提交给zookeeper？在每次成功使用消息后,我将关闭自动提交和提交偏移量.我似乎无法找到如何使用高级消费者执行此操作的实际代码示例.谁能帮我这个？

2. 另一方面,我听说承诺动物园管理员可能会很慢,所以另一种方式可能是在本地跟踪偏移？这种替代方法是否可取？如果是的话,你会怎么做？

现有流程响应用户输入更改表中预订记录的状态字段.

我有另一个要编写的进程,它将为具有特定状态的记录异步运行.它将读取表记录,执行一些操作(包括对第三方Web服务的调用),并更新记录的状态字段以指示处理已完成(或错误,错误计数).

此操作听起来非常类似于队列.在这种情况下使用MSMQ而不是SQL表有什么好处和权衡,为什么我要选择一个而不是另一个？

我们的软件是在表格中添加和更新记录.

这是一项将执行异步处理的新工作(Windows服务).这需要"永远向上".

虽然redis和消息排队软件通常用于不同的目的,但我想问一下使用redis的优缺点以下用例:

• 事件收集器组将传入消息写为键/值.消费者获取和删除已处理的密钥
• 负载从100k msg/s开始,在短时间内(如月)超过250k,目标是达到百万msg/s
• 坚持不是严格要求的.在失败期间丢失非日志消息是可以的
• 性能非常重要(因此,处理负载所需的系统数量)
• 消息不必按照它们到达的顺序进行处理

你知道redis选择传统消息排队软件的用例吗？或者你会考虑别的吗？

注意:我也看过这个但没有帮助: 实时应用新手 - Node.JS + Redis或RabbitMQ - >客户端/服务器怎么样？

谢谢

我没有太多的套接字编程经验,但我尝试了一下它.我对MDB和消息队列非常熟悉.有人告诉我队列(例如MDB)是"不比直接套接字连接多".有人可以比较这两个对我.

我正在为我的团队的一个应用程序研究排队解决方案.理想情况下,我们希望能够将其配置为轻量级进程内代理(用于线程之间的低吞吐量消息传递)和外部代理.是否有可以执行此操作的MQ服务器？大多数似乎都需要将设置作为外部实体.ZeroMQ似乎最接近于进程内解决方案,但它似乎更像是"类固醇上的UDP套接字",我们需要可靠的交付.

有一条消息(文本),我确定知道哪种格式和内容.
现在,实现了Java中用于从文件中解析和读取此消息的类.

在现实世界中,此消息将来自Message Queue.

现在我应该在我的本地PC上模拟,模拟或生成Message Queue以进行测试.

Java规范(java jms):

JMS provider: A messaging system that implements the JMS specification.
JMS clients: Java applications that send and receive messages.
Messages: Objects that are used to communicate information between JMS clients.

关于这个规范,我需要JMS提供者.

JMS客户端 - 这是我读取消息的类.
消息本身我知道.

那么问题是如何启动消息队列？
我如何从Java代码中以programmaticaly方式模拟它？我能以某种方式嘲笑它吗？

谢谢.

原谅我的无知,但是来自Django/Python背景我可以看到让Celery队列在后台运行较慢进程的巨大好处,同时尽可能快地更新Web界面.

但是,由于Node异步工作,队列系统的用例是否会大大减少？

例如:

1 - 用户向网站发布内容,2 - 网站响应,然后邮寄管理员.

在Django中,您将管理邮件发送到任务,稍后执行,然后响应请求.芹菜在后台发送邮件.

在Node中,您调用邮件程序,然后回复请求.然后邮件程序发送回叫以表示DONE与否,此时用户已经在查看响应.

那么我为什么要使用Node队列呢？我猜测事情比这更复杂 - 似乎对于像交易邮件那样的琐碎事情,它没有必要......

或者我误解了它的运作方式!？