连锁当家运维手册


php aliyun_kafka环境配置 ,使用

<p>安装 gcc ...等库</p> <pre><code>yum -y install gcc gcc-c++ wget</code></pre> <p>安装 re2c</p> <pre><code>yum -y install re2c</code></pre> <p>安装php (如果有的话不用安装)</p> <pre><code>yum install php70w php70w-pgsql php70w-mbstring php70w-pdo_dblib php70w-pdo php70w-pear php70w-devel -y</code></pre> <p>安装git软件</p> <pre><code>yum install git</code></pre> <p>下载librdkafka</p> <pre><code>git clone https://github.com/edenhill/librdkafka.git</code></pre> <p>进入目录</p> <pre><code>cd librdkafka/</code></pre> <p>配置</p> <pre><code>./configure</code></pre> <p>编译安装</p> <pre><code>make &amp;amp;&amp;amp; make install</code></pre> <p>下载rdkafka</p> <pre><code>git clone https://github.com/arnaud-lb/php-rdkafka.git</code></pre> <p>进入目录然后编译安装</p> <pre><code>cd php-rdkafka phpize ./configure make all -j 5 sudo make install</code></pre> <p>安装 rdkafka</p> <pre><code>pecl install rdkafka</code></pre> <p>用vi编辑 php.ini 添加以下内容</p> <pre><code>extension=rdkafka.so</code></pre> <p>重启apache服务</p> <pre><code>systemctl restart httpd</code></pre> <p>代码文件位置在shopos的svn中 </p> <pre><code>common/ca-cert //连接ali ca-cert配置文件 common/ali_kafka_conf.php //配置文件 vendor/fafka-ali/consumer.php //消费者 app/rpc_class/function/kafka-producer.php //生产者</code></pre> <p>common/ali_kafka_conf.php中配置参数 下面使用PLAIN连接方式: 所有语言可用;需要配置 AccessKey 完整的key,SecretKey 的后10位。</p> <pre><code>&amp;lt;?php return [ 'sasl_plain_username' =&amp;gt; 'LTAIqKssCYW2cY6r', //'sasl_plain_password' =&amp;gt; 'bfGpnORpEcwsCTi9pQEw96F7PRgII2', 'sasl_plain_password' =&amp;gt; '96F7PRgII2', 'bootstrap_servers' =&amp;gt; &amp;quot;kafka-ons-internet.aliyun.com:8080&amp;quot;, 'topic_name' =&amp;gt; 'credit_update_test', 'consumer_id' =&amp;gt; 'CID_WEIXIN' ]; </code></pre> <p>登陆linux (121.41.17.128)运行 </p> <pre><code>php /var/www/html/shopos.9isoft.com/kafka/vendor/kafka-ali/consumer.php</code></pre>

页面列表

ITEM_HTML