kafka集群安装

  • 下载安装
1
2
3
4
5
6
7
8
9
10
cd /usr/local
mkdir kafka
cd kafka
#下载 Kafka 软件包到当前目录中
wget http://labfile.oss.aliyuncs.com/courses/859/kafka_2.10-0.10.2.1.tgz  
tar -zxf kafka_2.10-0.10.2.1.tgz
mv kafka_2.10-0.10.2.1 kafka
# 后台启动zookepper
./zookeeper-server-start.sh ../config/zookeeper.properties &
jps查看是否启动成功
more >>

展开全文 >>

rabbitmq05 公平调度

公平调度

不知道你有没有发现，如果在启动worker前消息队列中已经存在很多个消息了，当启动worker的时候会一股脑的把所有的消息都拿过去。如果之前消息队列中有1W条消息，那这1W条消息要消费多久啊！！

消息长度定义
  • 使用basic_qos定义当前worker同一时间能够拿到手的消息的上限
    1
    channel.basic_qos(prefetch_count=1)

展开全文 >>

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

大树，<br>人在首都，就职猪厂,<br>测试开发一枚<br><br>骐骥一跃不能十步，驽马十驾功在不舍<br><br>qq:565506019<br>