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; 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>&lt;?php
return [
'sasl_plain_username' =&gt; 'LTAIqKssCYW2cY6r',
//'sasl_plain_password' =&gt; 'bfGpnORpEcwsCTi9pQEw96F7PRgII2',
'sasl_plain_password' =&gt; '96F7PRgII2',
'bootstrap_servers' =&gt; &quot;kafka-ons-internet.aliyun.com:8080&quot;,
'topic_name' =&gt; 'credit_update_test',
'consumer_id' =&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>