cmptmn_个人页

Re【7月11日更新】阿里中间件性能挑战赛第二赛季答疑汇总 不是说第二赛季通知本周以邮件形式发出的吗？怎么我还没收到邮件的？ ------------------------- Re【7月11日更新】阿里中间件性能挑战赛第二赛季答疑汇总 Q: 用orderid查询订单时，有没有可能查询一个在买家表、商品表中的字段？A: 可能的。复赛的查询的所有数据，都是基于在对三张表做了join的前提下进行查询。   * @param keys　如果为null，则查询所有字段，  Result queryOrder(long orderId, Collection keys); 是不是：@param keys　如果为null就查询三张表join后的所有字段。 ------------------------- Re【7月11日更新】阿里中间件性能挑战赛第二赛季答疑汇总 Q: 用orderid查询订单时，有没有可能查询一个在买家表、商品表中的字段？ A: 可能的。复赛的查询的所有数据，都是基于在对三张表做了join的前提下进行查询。 /**    * 查询订单号为orderid的指定字段    *    * @param orderid    *          订单号    * @param keys    *          待查询的字段，如果为null，则查询所有字段，如果为空，则排除所有字段    * @return 查询结果，如果该订单不存在，返回null    */   Result queryOrder(long orderId, Collection keys); 是不是可以理解为：@param keys　待查询的字段，如果为null就查询三张表join后的所有字段。 /**    * 查询某位买家createtime字段从[startTime, endTime) 时间范围内发生的所有订单的所有信息    *    * @param startTime 订单创建时间的下界    * @param endTime 订单创建时间的上界    * @param buyerid    *          买家Id    * @return 符合条件的订单集合，按照createtime大到小排列    */   Iterator queryOrdersByBuyer(long startTime, long endTime,       String buyerid); 是不是可以理解为：@return 符合条件的订单集合（包含三张表Join后的所有字段）。 /**    * 查询某位卖家某件商品所有订单的某些字段    *    * @param salerid 卖家Id    * @param goodid 商品Id    * @param keys 待查询的字段，如果为null，则查询所有字段，如果为空，则排除所有字段    * @return 符合条件的订单集合，按照订单id从小至大排序    */   Iterator queryOrdersBySaler(String salerid, String goodid,       Collection keys); 是不是可以理解为：@param keys 待查询的字段，如果为null，则查询三张表join后的所有字段。 /**    * 对某件商品的某个字段求和，只允许对long和double类型的KV求和 如果字段中既有long又有double，则使用double    * 如果求和的key中包含非long/double类型字段，则返回null 如果查询订单中的所有商品均不包含该字段，则返回null    *    * @param goodid 商品Id    * @param key 求和字段    * @return 求和结果    */   KeyValue sumOrdersByGood(String goodid, String key); 是不是可以理解为：如果查询订单中的所有商品或买家信息均不包含该字段，则返回null 最后，建议更新接口类的注释以免造成误解。 ------------------------- Re【7月11日更新】阿里中间件性能挑战赛第二赛季答疑汇总 最后，建议更新接口OrderSystem的注释以免造成误解。

Redemo中的bug报告 我也发现了这个问题把： list[0].payAmount = rand.nextInt((int) (orderMessage.getTotalPrice() / 2)); 改为： list[0].payAmount = rand.nextInt((int) ((orderMessage.getTotalPrice() + 2) / 2)); 就OK了 ------------------------- Redemo中的bug报告 是可能会出现负数据但不影响你的测试结果，我一直这样测试发现有问题。 ------------------------- Redemo中的bug报告 说错，应该是：可能会生成 payAmount为0的PaymentMessage，但不影响你的测试结果。

Re第一题每个topic提供一个消费组还是总共一个消费组？ 也就是说一个topic只能启一个spout，是吗?这样性能调整会受到限制，这个可是性能挑战赛呀，这种限制合理吗？ ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ 噢，刚刚才开始使用RocketMQ,对它了解不深。我是用DefaultMQPullConsumer的，发现用同一个consumerGroup创建多个DefaultMQPullConsumer对象会报错： Caused by: com.alibaba.rocketmq.client.exception.MQClientException: The consumer group[raceConsumerGroup] has been created before, specify another name please. See github.com/alibaba/RocketMQ/issues/40 for further details. 请问使用Pull方式拉RocketMQ的消息有哪个类可以使用同一个consumerGroup同时创建多个对象的？我想创建多个对象,每一个分别对应一个Topic中的一个MessageQueue来用Pull方式拉消息。 ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ 所以我才得出结论要不每个Topic只启一个spout用DefaultMQPullConsumer对象来拉消息，要不就用不同的consumerGroup创建多个DefaultMQPullConsumer对象同时来拉消息。 ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ 不是不行，只是不如每个MessageQueue分别用一个DefaultMQPullConsumer对象Pull拉消息的性能好。这个我做过测试了。 ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ 亲，一个Topic有多个MessageQueue（消息队列）的。 ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ hi，分析了一下RocketMQ的客户端代码发现“com.alibaba.rocketmq.client.exception.MQClientException: The consumer group[raceConsumerGroup] has been created before, specify another name please”异常的原因是：DefaultMQPullConsumerImpl在执行start方法时，向一个MQClientManager对象请求用consumerGroup对自己进行注册，并校验是否已经用相同的consumerGroup在MQClientManager对象中注册过了。如果已经注册过了就抛出上面的异常。而MQClientManager实例是个“单例”，在JVM内是全唯一的。所以在JVM内用同一个consumerGroup只能使用同一个DefaultMQPullConsumer对象，不能同时使用多个DefaultMQPullConsumer对象。但在不同的JVM内是可以用相同的consumerGroup分别创建并使用DefaultMQPullConsumerImpl对象的。所以在使用DefaultMQPullConsumerImpl时要用类变量进行引用，保证在整个JVM内共享同一个DefaultMQPullConsumerImpl实例如：static DefaultMQPullConsumer singleDefaultMQPullConsumer = new DefaultMQPullConsumer('raceConsumerGroup') ------------------------- Re第一题每个topic提供一个消费组还是总共一个消费组？ RocketMQ的文档少得可怜，遇到问题要自己翻代码才能解决。Jstorm的文档也是少得可怜幸好可以借鉴Storm的。阿里要想自己的开源项目象Kafka、Storm（Heron）、Hbase那样广泛被外界使用文档恐怕还要多下工夫呀！