落網數據庫簡單查詢接口 caddy+php7+mongodb

落網數據庫簡單查詢接口

一個簡單的DEMO，使用了caddy + php7 + mongodb

數據庫&接口設計 來自 https://github.com/Aedron/Luoo.spider 項目(V1.0版本分支)

參考地址：https://www.cnblogs.com/edit/p/luoo-service_caddy-php7-mongodb.html

 

環境配置：

下載程序，新建一個目錄，比如 C:\web

https://caddyserver.com/download 下載caddy並解壓到文件夾內，比如 C:\web\caddy_v1.0.0_windows_amd64

https://www.php.net/downloads.php 下載PHP7.3最新版並解壓到文件夾內，比如 C:\web\php-7.3.5-nts-Win32-VC15-x64

https://www.mongodb.com/download-center/community 下載MongoDB社區版zip包 並解壓到文件夾內，比如 C:\web\mongodb-win32-x86_64-2008plus-ssl-4.0.9

配置&啟動腳本:

【PHP 安裝mongodb拓展】 

https://pecl.php.net/package/mongodb 下載最新的stable版本，比如現在是1.5.3，點擊鏈接 “dll” ，在彈出的新頁面里找到對應你PHP版本的地址然后下載。

下載完成后把 tgz包里面的 php_mongodb.dll 解壓到 php 目錄下的 ext 文件夾內。

找到 php目錄下的 php.ini-production，復制一份並重命名為 php.ini  ，打開文件加入兩行配置

extension_dir = "ext"
extension = mongodb

【caddy 配置&啟動腳本】 

 caddy目錄下新建 root 文件夾，用來存放php或html頁面

 caddy目錄下新建文本文件 Caddyfile （不需要后綴名），寫入

訪問域名 {
	gzip
	tls 你的郵箱 #如果不需要https可刪除此行
	root C:\web\root
	errors {
		404 404.html # Not Found
	}
	on startup _php_cgi.bat &
	fastcgi php 127.0.0.1:6545 php
	rewrite /luoo/ {
		to {path} {path}/ /luoo.php?_url={path}&{query}
	}
	header /luoo {
		Access-Control-Allow-Origin  *
		Access-Control-Allow-Methods "GET, POST, OPTIONS"
	}
	header / {
		-Server 
		-X-Powered-By
	}
}

caddy目錄下新建文本文件 _php_cgi.bat，寫入

:start
    C:\web\php-7.3.5-nts-Win32-VC15-x64\php-cgi.exe -b 6545
    goto start

然后就可以 雙擊caddy.exe 啟動了，或者是配置成windows服務使用。

【Mongodb 配置&導入bson文件】 

Mongodb 目錄下新建 data 文件夾

Mongodb 目錄下新建文本文件 _start.bat，寫入

title MongoDB
cd bin
mongod --dbpath C:\web\mongodb-win32-x86_64-2008plus-ssl-4.0.9\data
pause

雙擊 _start.bat ，即可啟動 Mongodb 。

Mongodb 目錄下新建文本文件 _import.bat，寫入

title MongoDB import
echo MongoDB import
cd bin
mongorestore -d luoo C:\web\mongodb-win32-x86_64-2008plus-ssl-4.0.9\luoo
pause

順便去github上下載一份落網數據文件，地址在 https://github.com/Aedron/Luoo.spider/tree/master/db/luoo 

下載完成后，把 db目錄下的 luoo 文件夾拷貝到 Mongodb 目錄下，然后運行上面的 _import.bat 腳本，即可完成數據導入。

 

PHP代碼編寫：

在 C:\web\root 目錄下新建 luoo.php，寫入

<?php
header('Content-Type:application/json; charset=utf-8');
if(empty($_GET['_url'])){
    exit(json_encode(['code'=>'400','msg'=>'訪問異常']));
}
$router = explode('/',str_replace('/luoo/','',$_GET['_url']));
define('API_LIST', ['vol','vols','single','singles','article','latest']);
if(!in_array($router[0],API_LIST)){
    exit(json_encode(['code'=>'404','msg'=>'接口不存在']));
}
class Luoo{
    private $manager;
    private $config = ["latestVol"=>997,"latestSingle"=>20170721,"latestArticle"=>927];
    public function __construct(){
        $this->manager = new MongoDB\Driver\Manager();
    }
    private function getCount($collection,$where=[]){
        $command = new MongoDB\Driver\Command(['count' => $collection,'query'=>$where]);
        $result = $this->manager->executeCommand('luoo',$command);
        $response = current($result->toArray());
        if($response->ok==1){
            return $response->n;
        }
        return 0;
    }
    private function getLyric($param){
        $query = new MongoDB\Driver\Query($param,['projection'=>['_id' => 0],'limit'=>100]);
        $cursor = $this->manager->executeQuery('luoo.lyrics', $query);
        return $cursor->toArray();
    }
    public function vol(int $vol){
        $query = new MongoDB\Driver\Query(['vol'=>$vol], ['projection'=>['_id' => 0],'limit'=>1]);
        $cursor = $this->manager->executeQuery('luoo.vols', $query);
        $result = ['code'=>200];
        $result['data'] = current($cursor->toArray());
        if($result['data'] && $result['data']->id){
            $volId = $result['data']->id;
            $result['data']->lyrics = $this->getLyric(['volId'=>$volId]);
        }
        echo json_encode($result);
    }
    public function vols(int $date){
        $page = $_GET['page']??1;
        $where = ['vol'=>['$gte'=>$date]];
        $options = ['projection'=>['_id' => 0],'limit'=>10,'sort'=>['vol' => 1]];
        if($page>1) $options['skip'] = ($page-1)*10;
        $count = $this->getCount('singles',$where);
        $query = new MongoDB\Driver\Query($where, $options);
        $cursor = $this->manager->executeQuery('luoo.vols', $query);
        $result = ['code'=>200];
        $result['page'] = $page;
        $result['total'] = $count;
        $result['data'] = $cursor->toArray();
        echo json_encode($result);
    }
    public function single(int $date){
        $query = new MongoDB\Driver\Query(['date'=>$date],['projection'=>['_id' => 0],'limit'=>1]);
        $cursor = $this->manager->executeQuery('luoo.singles', $query);
        $result = ['code'=>200];
        $result['data'] = current($cursor->toArray());
        if($result['data'] && $result['data']->id){
            $result['data']->lyrics = $this->getLyric(['type'=>1,'date'=>$date]);
        }
        echo json_encode($result);
    }
    public function singles(int $date){
        $page = $_GET['page']??1;
        $where = ['date'=>['$gte'=>$date]];
        $options = ['projection'=>['_id' => 0],'limit'=>10,'sort'=>['date' => 1]];
        if($page>1) $options['skip'] = ($page-1)*10;
        $count = $this->getCount('singles',$where);
        $query = new MongoDB\Driver\Query($where, $options);
        $cursor = $this->manager->executeQuery('luoo.singles', $query);
        $result = ['code'=>200];
        $result['page'] = $page;
        $result['total'] = $count;
        $result['data'] = $cursor->toArray();
        echo json_encode($result);
    }
    public function article(int $id){
        $query = new MongoDB\Driver\Query(['id'=>$id], ['projection'=>['_id' => 0],'limit'=>1]);
        $cursor = $this->manager->executeQuery('luoo.articles', $query);
        $result = ['code'=>200];
        $result['data'] = current($cursor->toArray());
        if($result['data'] && $result['data']->id){
            $articleId = $result['data']->id;
            $result['data']->lyrics = $this->getLyric(['articleId'=>$articleId]);
        }
        echo json_encode($result);
    }
    public function latest(string $type){
        switch (strtolower($type)) {
            case 'vol':
                $this->vol($this->config['latestVol']);
                break;
            case 'single':
                $this->single($this->config['latestSingle']);
                break;
            case 'article':
                $this->article($this->config['latestArticle']);
                break;
            default:
                echo json_encode(['code'=>'400','msg'=>'允許的 type 為 vol 或 single 或 article']);
                break;
        }
    }
}
try {
    $LUOO = new Luoo();
    $LUOO->{$router[0]}($router[1]);
}
catch (TypeError $ex) { exit(json_encode(['code'=>'400','msg'=>'請求參數有誤']));}
catch (Error $ex) { exit(json_encode(['code'=>'500','msg'=>'服務器內部錯誤']));}

API列表如下：

/vol/<volIndex>
根據期刊數來獲取期刊數據, /vol/717
/vols/<volIndex>
根據當前期刊數來獲取該期刊之后的所有新的期刊數據, 如 /vols/926

/single/<singleDate>
根據發布日期來獲取單曲數據, 如 /single/20160722
/singles/<singleDate>
根據當前發布日期來獲取該發布日期之后的所有新的單曲數據, 如 /singles/20170628

/article/<articleIndex>
根據文章id來獲取文章數據, 如 /article/922

/latest/<type>
獲取最新的期刊或單曲或文章, 允許的 type 為 vol 或 single 或 article, 如 /latest/vol

 來源地址： https://www.cnblogs.com/edit/p/10880194.html