小编Diy*_*yko的帖子

我们对AMQ使用以下配置

<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${brokerURL1}"/>
</bean>
<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
    <property name="maxConnections" value="10"/>
    <property name="maximumActive" value="100"/>
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
    <property name="concurrentConsumers" value="5"/>
    <property name="maxConcurrentConsumers" value="10"/>
</bean>

<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="configuration" ref="jmsConfig"/>
</bean>

我经常有一个奇怪的问题 - 松散的信息.实际上AMQ表示一切正常并且消息已经出列但是应用程序上没有消息...

我已经读过它可能是缓存消费者的问题,而应该在配置后使用JmsConfiguration

<bean id="jmsConfig" class="org.apache.activemq.camel.component.ActiveMQConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
    <property name="concurrentConsumers" value="5"/>
    <property name="maxConcurrentConsumers" value="10"/>
    <property name="cacheLevelName" value="CACHE_CONSUMER"/>
</bean>

有谁知道如何正确配置activemq？哪些值应设置为最佳性能和良好的可靠性？

<property name="maxConnections" value="?"/>
<property name="maximumActive" value="?"/>
<property name="concurrentConsumers" value="?"/>
<property name="maxConcurrentConsumers" value="?"/> …

我们正在开发相当大的服务器应用.每个操作都由日志跟踪.调用toString方法的日志很多.不幸的是,我们需要其中大部分,另一方面我们无法追踪生产中发生的事情.尝试改进toString方法是否有意义？例如,将toString的结果放在内存中,并在某些字段更新时更新.

example of my toString
public classs InMessage{
//declared 20+ fields
     @Override
      public String toString() {
       StringBuilder builder = new StringBuilder(this.getClass().getSimpleName());
       builder.append(": [");
       builder.append(super.toString());
       builder.append("; updateTime: ");
       builder.append(updateTime);
       //forexample 20 fields here
       builder.append(";]");
       return builder.toString();
     }}
then we process InMessage in some way and log each action
     log.debug("We received inMessage: {}", inMessage);

在讨论之后,我们决定减少可能的日志数量,仅此而已.

我们的测试工具创建n个线程，并在每个线程内执行m次迭代。我们计算最小，平均和最大操作时间。因此，我们会不时看到mongo执行请求的速度非常慢-长达几秒钟。同样，每次首次操作最慢时，我们甚至有意将其从统计数据中排除，而avg和max之间的差异仍然很大。正常吗 我可以消除那些缓慢的操作吗？为什么mongo执行某些请求的速度如此之慢？

下面是我们同时运行插入/获取/删除/更新测试时的单操作模式和混合模式的结果。在混合模式下，thread = 1表示我们为每种测试类型创建了4个线程

我们使用默认值-每个主机100个连接

资源

public void storeMt(MyTestObject myTestObject) {
    mongoTemplate.insert(myTestObject );
  }

  public MyTestObject getMt(long id) {
    MyTestObject result = mongoTemplate.findById(id, MyTestObject.class);
    return result;
  }


@Document
public class MyTestObject implements Serializable {

  private static final long serialVersionUID = 1L;
  @Id
  private long id;
//class contains 20+ fields
.......