cmptmn_个人页

个人头像照片 cmptmn
个人头像照片
0
3
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力:

暂时未有相关通用技术能力~

云产品技术能力:

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息
暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2016-07-15

    【7月11日更新】阿里中间件性能挑战赛 - 第二赛季答疑汇总

    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的注释以免造成误解。
    踩0 评论0
  • 回答了问题 2016-06-24

    demo中的bug报告

    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,但不影响你的测试结果。
    踩0 评论0
  • 回答了问题 2016-06-24

    第一题每个topic提供一个消费组还是总共一个消费组?

    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那样广泛被外界使用文档恐怕还要多下工夫呀!
    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息