1. 　 阿里云服务器1888元代金券领取
  2. 　 本网站所有源码包解压密码：www.youhutong.com
登录 　帮助问答

Composer安装和使用教程 - Windows版（ PHP 的一个依赖管理工具）

小川 技术文章

Composer安装教程 - Windows：

1、下载Composer： Composer-Setup.exe 。然后运行就行了。唯一注意的就是安装时要选择php.exe   

  

        这是安装Composer 最简单的方法，

        它将安装最新版本的 Composer ，并设置好系统的环境变量。

        因此你可以在任何目录下    直接使用 composer 命令。


Composer使用教程：

案例1：用Composer来生成php版的elasticsearch框架

1、声明依赖关系：

        比方说，你的项目中需要一个php版的elasticsearch框架。为了将它添加到你的项目中（下载），你所需要做的就是创建一个 composer.json 文件，其中描述了项目的依赖关系。注意文件要放在你执行composer命令的目录中

{
	"require":{
		"elasticsearch/elasticsearch":"~2.0"
	}
}


2、cmd切换到要下载elasticsearch框架的目录，然后执行命令：composer install

     如有出错误信息：

      [Composer\Downloader\TransportException]

      Content-Length mismatch, received 583439 bytes out of the expected 1215108

     解决办法：切换国内镜像地址，再执行操作

      1、通过命令切换如下：（最终修改的是composer.json）

      composer config -g repo.packagist composer https://packagist.phpcomposer.com

      2、直接修改 composer.json （其实跟方法1是一样的。）

{
	"require":{
		"elasticsearch/elasticsearch":"~2.0"
	},
	"repositories": {
		"packagist": {
			"type": "composer",
			"url": "https://packagist.phpcomposer.com"
		}
	}
}


001.png


3、PHP使用：


下面我们讲一下基本使用方法，需要获取更多使用教程和方法请看官方文档：https://www.elastic.co/guide/en/elasticsearch/client/php-api/current/_overview.html


想直接通过文件查看其他方法可以打开以下文件查看（基本使用的方法都在里面）：

1、\elasticsearch\src\Elasticsearch\Client.php中的方法

2、\elasticsearch\Namespaces\IndicesNamespace.php中的方法



ThinkPHP用法：

<?php
/**
 * Elasticsearch检索引擎模型
 */
namespace app\index\model;
use Elasticsearch\ClientBuilder;  
  
class Elasticsearch
{
    //配置
    private $config = [
        'hosts' => ['http://127.0.0.1:9200']
    ];
    private $api;
    public function __construct()
    {
        #include(APP_PATH .'/vendor/autoload.php');
        #require_once EXTEND_PATH . 'org/elasticsearch/autoload.php';
        import('org.elasticsearch.autoload', EXTEND_PATH);
        $this->api = ClientBuilder::create()->setHosts($this->config['hosts'])->build(); 
    }

    /*************************************************************
    /**
     * 索引一个文档
     * 说明：索引没有被创建时会自动创建索引
     */
    public function addOne()
    {
        $params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['id']  = '20180407001';  # 不指定就是es自动分配
		$params['body']  = array('name' => '小川编程');  
		return $this->api->index($params);
    }

    /**
     * 索引多个文档
     * 说明：索引没有被创建时会自动创建索引
     */
    public function addAll()
    {
    	$params = [];
        for($i = 1; $i < 21; $i++) {  
		    $params['body'][] = [
		        'index' => [
					'_index' => 'test_index'.$i,
					'_type'  => 'cat_test',
					'_id'	 => $i,
				]
		    ];  
		    $params['body'][] = [  
		        'name' => '小川编程'.$i,  
		        'content' => '内容'.$i  
		    ];
		}  
		return $this->api->bulk($params);  
    }

    /**
     * 获取一个文档
     */
    public function getOne()
    {
    	$params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['id']    = '20180407001';  
		return $this->api->get($params); 
    }

    /**
     * 搜索文档
     */
    public function search()
    {
    	$params = [];
    	$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['body']['query']['match']['name'] = '小川编程';  
		return $this->api->search($params); 
    }

    /**
     * 删除文档
     * 说明：文档删除后，不会删除对应索引。
     */
    public function delete()
    {
    	$params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type'] = 'cat';  
		$params['id'] = '20180407001';  
		return $this->api->delete($params);  
    }

    /*************************************************************
    /**
     * 创建索引
     */
    public function createIndex()
    {
    	$params = [];
		$params['index']  = 'xiaochuan'; 
		return $this->api->indices()->create($params);  
    }
  	
  	/**
     * 删除索引：匹配单个 | 匹配多个
     * 说明： 索引删除后，索引下的所有文档也会被删除
     */
  	public function deleteIndex()
  	{	
  		$params = [];
  		$params['index'] = 'test_index';  # 删除test_index单个索引
  		#$params['index'] = 'test_index*'; # 删除以test_index开始的所有索引
		return $this->api->indices()->delete($params);  
  	}

  	/*************************************************************
  	/**
     * 设置索引配置
     */
  	public function setIndexConfig()
  	{	
  		$params = [];
  		$params['index'] = 'xiaochuan';  
		$params['body']['index']['number_of_replicas'] = 0;  
		$params['body']['index']['refresh_interval'] = -1;  
		return $this->api->indices()->putSettings($params);  
  	}

  	/**
     * 获取索引配置
     */
  	public function getIndexConfig()
  	{
  		# 单个获取条件写法
		$params['index'] = 'xiaochuan';  
		# 多个获取条件写法
		//$params['index'] = ['xiaochuan', 'test_index'];  
		return $this->api->indices()->getSettings($params);  
  	}

	/**
     * 设置索引映射
     */
  	public function setIndexMapping()
  	{
  		#  设置索引和类型 
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		  
		#  向现有索引添加新类型
		$myTypeMapping = array(  
		    '_source' => array(  
		        'enabled' => true  
		    ),  
		    'properties' => array(  
		        'first_name' => array(  
		            'type' => 'string',  
		            'analyzer' => 'standard'  
		        ),  
		        'age' => array(  
		            'type' => 'integer'  
		        )  
		    )  
		);  
		$params['body']['cat'] = $myTypeMapping;  
		  
		#  更新索引映射 
		$this->api->indices()->putMapping($params);  
  	}

  	/**
     * 获取索引映射
     */
  	public function getIndexMapping()
  	{	
  		#  获取所有索引和类型的映射  
		$ret = $this->api->indices()->getMapping();  
		
		/*  
		#  获取索引为：xiaochuan的映射
		$params['index'] = 'xiaochuan';  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取类型为：cat的映射
		$params['type'] = 'cat';  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取（索引为：xiaochuan和 类型为：cat）的映射
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat'  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取索引为：xiaochuan和test_index的映射
		$params['index'] = ['xiaochuan', 'test_index'];  
		$ret = $this->api->indices()->getMapping($params); 
		*/

		return $ret;
  	}


}


其他形式用法测试：

test.php

<?php   
require_once('vendor/autoload.php');  
use Elasticsearch\ClientBuilder;  
  
  
function get_conn(){  
    $host = 'localhost';  
    $dbname = 'mraz';  
    $user = 'root';  
    $passwd = '111111';  
  
  
    $conn = new PDO("mysql:dbname=$dbname;host=$host",$user,$passwd);  
    return $conn;  
}  
  
  
function create_index(){  
    //Elastic search php client  
  
  
  
  
    $client = Elasticsearch\ClientBuilder::create()->build();  
    $sql    = "SELECT * FROM emp";  
    $conn   = get_conn();  
    $stmt   = $conn->query($sql);  
    $rtn    = $stmt->fetchAll();  
  
  
    //delete index which already created  
    $params = array();  
    $params['index'] = 'emp_index';  
    $client->indices()->delete($params);  
      
    //create index on log_date,src_ip,dest_ip  
    $rtnCount = count($rtn);  
    for($i=0;$i<$rtnCount;$i++){  
        $params = array();  
        $params['body'] = array(  
            'id'       => $rtn[$i]['id'],  
            'fdName'   => $rtn[$i]['fdName'],  
            'fdAge'    => $rtn[$i]['fdAge'],  
            'fdStatus' => $rtn[$i]['fdStatus']  
        );  
        $params['index'] = 'emp_index';  
        $params['type']  = 'emp_type';  
          
        //Document will be indexed to log_index/log_type/autogenerate_id          
        $client->index($params);  
    }  
    echo 'create index done!';  
}  
  
  
function search(){  
    //Elastic search php client  
    $client = Elasticsearch\ClientBuilder::create()->build();  
    $params = array();  
    $params['index'] = 'emp_index';  
    $params['type'] = 'emp_type';  
    $params['body']['query']['match']['fdStatus'] = '1';  
    $params['body']['sort'] = array('fdAge'=>array('order'=>'desc'));  
    $params['size'] = 3;    
    $params['from'] = 1;    
    $rtn = $client->search($params);  
    var_dump($rtn);  
}  
  
  
set_time_limit(0);  
// create_index();  
search();  
?>


1）创建：

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log';  //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$data['body']['settings']['number_of_shards'] = 5;  //主分片数量  
$data['body']['settings']['number_of_replicas'] = 0; //从分片数量  
$elastic->indices()->create($index);

2）插入索引数据：

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['id'] = 1   //不指定id，系统会自动生成唯一id  
$index['body'] = array(  
  'mac' => 'fcd5d900beca',  
  'customer_id' => 3,  
  'product_id' => 5,  
  'version' => 2  
);  
$elastic->index($index);

3）查询：

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['match']['mac'] = 'fcd5d900beca';  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac='fcd5d900beca' limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['must'] = array(  
    array('match' => array('mac' => 'fcd5d900beca')),  
    array('match' => array('product_id' => 20))  
   );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac='fcd5d900beca' and product_id=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['should'] = array(  
      array('match' => array('mac' => 'fcd5d900beca')),  
      array('match' => array('product_id' => 20))  
     );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#当于sql语句:select*from ems_run_log where mac='fcd5d900beca' or product_id=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['must_not'] = array(  
   array('match' => array('mac' => 'fcd5d900beca')),  
   array('match' => array('product_id' => 20))  
  );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac!='fcd5d900beca' and product_id!=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['range'] = array(  
   'id' => array('gte' => 20,'lt' => 30);  
 );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where id>=20 and id<30  limit 200,10;

4）删除文档：

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'test';  //索引名称  
$index['type'] = 'ems_test'; //类型名称  
$index['id'] = 2;   
$elastic->delete($index);


　浏览器启用弹出窗口过滤功能，将无法跳转到下载页。在浏览器地址栏右边符号提示处点击允许就可以了！

转载请注明来源地址：小川编程 » https://www.youhutong.com/index.php/article/index/211.html

php技术文章
( 0 )个小伙伴在吐槽
    登录帐号　　如果已经登录请刷新！ 发表我的评论
    表情

    邮件订阅

    填写您的邮件地址，订阅更多的精彩内容：

    标签

    . . .
    php程序 (1596) python程序 (15) java程序 (36) 微信小程序 (251) app程序 (84) 其他程序 (495) UI组件 (103) 输入组件 (26) 媒体组件 (82) 导航组件 (14) 动画特效 (268) 其他组件 (18) 前台html模板 (182) 后台html模板 (11) 苹果cms (40) discuz (1) wordpress (183) 帝国cms (29) 织梦dedecms (271) 其他插件 (23) php技术文章 (111) python技术文章 (0) 前端技术文章 (20) android技术文章 (6) 微信技术文章 (2) ios技术文章 (0) linux技术文章 (16) mysql技术文章 (8) 游戏程序 (384) emlog (53) zblog (10) 实用软件 (101) 视频教程 (4)

    分类

    . . .
    网站程序 (1745) 游戏程序 (362) 模板插件 (362) 特效组件 (288) 视频教程 (4) 实用软件 (91) 全部源码 (2864) 技术文章 (134)

    热门文章

    近期文章