php实现redis的服务端的示例

php实现redis就是像php与mysql数据库一样进行一些操作了，我们这里来看一篇关于php实现redis的服务端的示例吧，具体的细节如下文介绍。

大家都知道redis是用C来实现的，现在我用php来实现一个简单的仅支持SET和GET命令的redis服务端，主要是为了更好的了解redis的服务端和php的网络编程.

代码如下：

<?php
/**
 * 多进程阻塞式
 */
class Xtgxiso_server
{
    private $socket = false;
    private $process_num = 100;
    public $redis_kv_data = array();
    public $onMessage = null;

    function __construct($host="0.0.0.0",$port=1215)
    {
        $this->socket = stream_socket_server("tcp://".$host.":".$port,$errno, $errstr);
        if (!$this->socket) die($errstr."--".$errno);
        echo "listen $host $port \r\n";
        ini_set("memory_limit", "128M");
    }

    private function parseRESP(&$conn){
        $line = fgets($conn);
        if($line === '' || $line === false)
        {
            return null;
        }
        $type = $line[0];
        $line = mb_substr($line,1,-2);
        switch ( $type ){
            case "*":
                $count = (int) $line;
                $data = array();
                for ($i = 1; $i <= $count; $i++) {
                    $data[] = $this->parseRESP($conn);
                }
                return $data;
            case "$":
                if ($line == '-1') {
                    return null;
                }
                $length = $line + 2;
                $data = '';
                while ($length > 0) {
                    $block = fread($conn, $length);
                    if ($length !== strlen($block)) {
                        throw new Exception('RECEIVING');
                    }
                    $data .= $block;
                    $length -= mb_strlen($block);
                }
                return mb_substr($data, 0, -2);
        }
        return $line;
    }

    private function start_worker_process(){
        $pid = pcntl_fork();
        switch ($pid) {
            case -1:
                echo "fork error : {$i} \r\n";
                exit;
            case 0:
                while ( 1 ) {
                    echo  "waiting...\n";
                    $conn = stream_socket_accept($this->socket, -1);
                    if ( !$conn ){
                        continue;
                    }
                    //"*3\r\n$3\r\nSET\r\n$5\r\nmykey\r\n$7\r\nmyvalue\r\n"
                    while(1){
                        $arr = $this->parseRESP($conn);
                        if ( is_array($arr) ) {
                            if ($this->onMessage) {
                                call_user_func($this->onMessage, $conn, $arr);
                            }
                        }else if ( $arr ){
                            if ($this->onMessage) {
                                call_user_func($this->onMessage, $conn, $arr);
                            }
                        }else{
                            fclose($conn);
                            break;
                        }
                    }
                }
            default:
                $this->pids[$pid] = $pid;
                break;
        }
    }

    public function run(){
        for($i = 1; $i <= $this->process_num; $i++){
            $this->start_worker_process();
        }

        while(1){
            foreach ($this->pids as $i => $pid) {
                if($pid) {
                    $res = pcntl_waitpid($pid, $status,WNOHANG);

                    if ( $res == -1 || $res > 0 ){
                        $this->start_worker_process();
                        unset($this->pids[$pid]);
                    }
                }
            }
            sleep(1);
        }
    }

}
$server =  new Xtgxiso_server();

$server->onMessage = function($conn,$info) use($server){
    if ( is_array($info) ){
        if ( $info["0"] == "SET" ) {
            $key = $info[1];
            $val = $info[2];
            $server->redis_kv_data[$key] = $val;
            fwrite($conn, "+OK\r\n");
        }else if ( $info["0"] == "GET" ){
            $key = $info[1];
            fwrite($conn, "$".strlen($server->redis_kv_data[$key])."\r\n".$server->redis_kv_data[$key]."\r\n");
        }else{
            fwrite($conn,"+OK\r\n");
        }
    }else{
        fwrite($conn,"+OK\r\n");
    }
};

$server->run();
通过如下命令来测试PHP实现的性能：

redis-benchmark -h 10.170.233.221 -p 1215 -t set -n 80000 -q

 

看来还是不错的，大家有兴趣可以再实现其他命令！

php语言实现redis的客户端与服务端有一些区别了因为前面介绍过服务端了这里我们来介绍客户端吧，希望文章对各位有帮助。

为了更好的了解redis协议，我们用php来实现一个支持大部份命令的客户端类.

redis的协议可参考这个文章http://redis.cn/topics/protocol.html

代码如下：

<?php
namespace xtgxiso;
class Redis {
    private $redis_socket = false;
    private $cmd = '';
    public function __construct($host='127.0.0.1',$port=6379,$timeout = 3) {
        $this->redis_socket = stream_socket_client("tcp://".$host.":".$port, $errno, $errstr,  $timeout);
        if ( !$this->redis_socket) {
            throw new Exception("{$errno} - {$errstr}");
        }
    }
    public function __destruct() {
        fclose($this->redis_socket);
    }
    public function __call($name, $args) {
        $crlf = "\r\n";
        array_unshift($args,$name);
        $command = '*' . count($args) . $crlf;
        foreach ($args as $arg) {
            $command .= '$' . strlen($arg) . $crlf . $arg . $crlf;
        }
        $fwrite = fwrite($this->redis_socket,$command);
        if ($fwrite === FALSE || $fwrite <= 0) {
            throw new Exception('Failed to write entire command to stream');
        }
        return $this->readResponse();
    }
    private function readResponse() {
        $reply = trim(fgets($this->redis_socket, 1024));
        switch (substr($reply, 0, 1)) {
            case '-':
                throw new Exception(trim(substr($reply, 4)));
                break;
            case '+':
                $response = substr(trim($reply), 1);
                if ($response === 'OK') {
                    $response = TRUE;
                }
                break;
            case '$':
                $response = NULL;
                if ($reply == '$-1') {
                    break;
                }
                $read = 0;
                $size = intval(substr($reply, 1));
                if ($size > 0) {
                    do {
                        $block_size = ($size - $read) > 1024 ? 1024 : ($size - $read);
                        $r = fread($this->redis_socket, $block_size);
                        if ($r === FALSE) {
                            throw new Exception('Failed to read response from stream');
                        } else {
                            $read += strlen($r);
                            $response .= $r;
                        }
                    } while ($read < $size);
                }
                fread($this->redis_socket, 2); /* discard crlf */
                break;
            /* Multi-bulk reply */
            case '*':
                $count = intval(substr($reply, 1));
                if ($count == '-1') {
                    return NULL;
                }
                $response = array();
                for ($i = 0; $i < $count; $i++) {
                    $response[] = $this->readResponse();
                }
                break;
            /* Integer reply */
            case ':':
                $response = intval(substr(trim($reply), 1));
                break;
            default:
                throw new RedisException("Unknown response: {$reply}");
                break;
        }
        return $response;
    }
}
/*
$redis = new Client_test();
var_dump($redis->auth("123456"));
var_dump($redis->set("xtgxiso",'abc'));
var_dump($redis->get("xtgxiso"));
*/
通过实现，我们基本了解redis的协议。

curl默认是不能访问https了如果要curl访问https我们需要进行一些参数配置了，下面我们来看一篇关于php curl访问调用https时报错解决办法吧。

PHP 调用CURL提示错误：SSL certificate problem, verify that the CA cert is OK. Details: error:14090086:SSL routines:ssl3_get_server_certificate:certificate verify failed。这个是因为证书过期导致的。
SSL-ERROR

需要到 http://curl.haxx.se/ca/cacert.pem 下载信任证书。下载后，使其生效有两种方法：

第一种方法：修改 php.ini，找到 [curl]节点，如果没有，可以在php.ini底部添加。

[curl]
;修改为 http://curl.haxx.se/ca/cacert.pem 保存的路径
curl.cainfo="d:/php/cacert.pem"

第二种方法：保存到 程序所在目录，在调用curl的时候，增加一句：

<?php
    
    #cacert.pem 到 http://curl.haxx.se/ca/cacert.pem 下载
    curl_setopt($curl, CURLOPT_CAINFO, dirname(__FILE__) . '/cacert.pem');
?>

 

可以使用下面代码，自动识别https或http

function curlPost($url, $data, $timeout = 30)
 {
     $ssl = substr($url, 0, 8) == "https://" ? TRUE : FALSE;
     $ch = curl_init();
     $opt = array(
             CURLOPT_URL     => $url,
             CURLOPT_POST    => 1,
             CURLOPT_HEADER  => 0,
             CURLOPT_POSTFIELDS      => (array)$data,
             CURLOPT_RETURNTRANSFER  => 1,
             CURLOPT_TIMEOUT         => $timeout,
             );
     if ($ssl)
     {
         $opt[CURLOPT_SSL_VERIFYHOST] = 1;
         $opt[CURLOPT_SSL_VERIFYPEER] = FALSE;
     }
     curl_setopt_array($ch, $opt);
     $data = curl_exec($ch);
     curl_close($ch);
     return $data;
 }
 $data = curlPost('https://www.111cn.net', array('p'=>'hello'));
 echo ($data);
 

PHP检查移动设备只要通过TTP_USER_AGENT就可以进行识别了这样我们只要提前定义好我们目前市面上常用的TTP_USER_AGENT设置即可，下面我们就来看看判断移动设备常用例子吧。

不废话上代码，使用方法就是

代码如下

复制代码

<?php if(isMobile()){} if(!isMobile()){}  ?> function isMobile() { $user_agent = $_SERVER['HTTP_USER_AGENT']; $mobile_agents = Array("240x320", "acer", "acoon", "acs-", "abacho", "ahong", "airness", "alcatel", "amoi", "android", "anywhereyougo.com", "applewebkit/525", "applewebkit/532", "asus", "audio", "au-mic", "avantogo", "becker", "benq", "bilbo", "bird", "blackberry", "blazer", "bleu", "cdm-", "compal", "coolpad", "danger", "dbtel", "dopod", "elaine", "eric", "etouch", "fly ", "fly_", "fly-", "go.web", "goodaccess", "gradiente", "grundig", "haier", "hedy", "hitachi", "htc", "huawei", "hutchison", "inno", "ipad", "ipaq", "ipod", "jbrowser", "kddi", "kgt", "kwc", "lenovo", "lg ", "lg2", "lg3", "lg4", "lg5", "lg7", "lg8", "lg9", "lg-", "lge-", "lge9", "longcos", "maemo", "mercator", "meridian", "micromax", "midp", "mini", "mitsu", "mmm", "mmp", "mobi", "mot-", "moto", "nec-", "netfront", "newgen", "nexian", "nf-browser", "nintendo", "nitro", "nokia", "nook", "novarra", "obigo", "palm", "panasonic", "pantech", "philips", "phone", "pg-", "playstation", "pocket", "pt-", "qc-", "qtek", "rover", "sagem", "sama", "samu", "sanyo", "samsung", "sch-", "scooter", "sec-", "sendo", "sgh-", "sharp", "siemens", "sie-", "softbank", "sony", "spice", "sprint", "spv", "symbian", "tablet", "talkabout", "tcl-", "teleca", "telit", "tianyu", "tim-", "toshiba", "tsm", "up.browser", "utec", "utstar", "verykool", "virgin", "vk-", "voda", "voxtel", "vx", "wap", "wellco", "wig browser", "wii", "windows ce", "wireless", "xda", "xde", "zte"); $is_mobile = false; foreach ($mobile_agents as $device) {   if (stristr($user_agent, $device)) {     $is_mobile = true;     break;   } } return $is_mobile; }

网友补充了一个

代码如下

复制代码

<?php function isMobile() {     // 如果有HTTP_X_WAP_PROFILE则一定是移动设备     if (isset ($_SERVER['HTTP_X_WAP_PROFILE']))     {         return true;     }     // 如果via信息含有wap则一定是移动设备,部分服务商会屏蔽该信息     if (isset ($_SERVER['HTTP_VIA']))     {         // 找不到为flase,否则为true         return stristr($_SERVER['HTTP_VIA'], "wap") ? true : false;     }     // 脑残法，判断手机发送的客户端标志,兼容性有待提高     if (isset ($_SERVER['HTTP_USER_AGENT']))     {         $clientkeywords = array ('nokia',             'sony',             'ericsson',             'mot',             'samsung',             'htc',             'sgh',             'lg',             'sharp',             'sie-',             'philips',             'panasonic',             'alcatel',             'lenovo',             'iphone',             'ipod',             'blackberry',             'meizu',             'android',             'netfront',             'symbian',             'ucweb',             'windowsce',             'palm',             'operamini',             'operamobi',             'openwave',             'nexusone',             'cldc',             'midp',             'wap',             'mobile'             );         // 从HTTP_USER_AGENT中查找手机浏览器的关键字         if (preg_match("/(" . implode('|', $clientkeywords) . ")/i", strtolower($_SERVER['HTTP_USER_AGENT'])))         {             return true;         }     }     // 协议法，因为有可能不准确，放到最后判断     if (isset ($_SERVER['HTTP_ACCEPT']))     {         // 如果只支持wml并且不支持html那一定是移动设备         // 如果支持wml和html但是wml在html之前则是移动设备         if ((strpos($_SERVER['HTTP_ACCEPT'], 'vnd.wap.wml') !== false) && (strpos($_SERVER['HTTP_ACCEPT'], 'text/html') === false || (strpos($_SERVER['HTTP_ACCEPT'], 'vnd.wap.wml') < strpos($_SERVER['HTTP_ACCEPT'], 'text/html'))))         {             return true;         }     }     return false; } ?>

国外人喜欢写类，有一个Mobile Detect

Mobile_Detect 简单使用实例

代码如下

复制代码

include 'Mobile_Detect.php'; $detect = new Mobile_Detect();   // Check for any mobile device. if ($detect->isMobile())   // Check for any tablet. if($detect->isTablet())   // Check for any mobile device, excluding tablets. if ($detect->isMobile() && !$detect->isTablet())   if ($detect->isMobile() && !$detect->isTablet())   // Alternative to $detect->isAndroidOS() $detect->is('AndroidOS');   // Batch usage foreach($userAgents as $userAgent){   $detect->setUserAgent($userAgent);   $isMobile = $detect->isMobile(); }   // Version check. $detect->version('iPad'); // 4.3 (float)

下面我们来看一篇关于CSS 滤镜效果：模糊、灰度、亮度的一个教程，这篇文章是一站长转国外的哦，希望此文章能够帮助到各位朋友。

滤镜原本是 SVG 规范中的一部分。然而，当滤镜的用途变得更广泛时，W3C 也开始给 CSS 增加了一些常用的滤镜效果。CSS 滤镜非常强大又好用，你可以用它来模糊，变亮或饱和度以调整图像。这些滤镜可以单独使用也可以和其它的滤镜组合使用，滤镜的 CSS 语法是这样的：

filter: <filter-function> [<filter-function>]* | none

 
现在开始，我将对这些滤镜做一下简要的介绍。

亮度

该滤镜控制图像的亮度。它可以接受大于或等于零的值作为它的参数。值为 0％ 时将变成黑色。值为 100％ 时则是原始图像。你可以指定大于 100％ 的值以得到更明亮的图像。比如设为 300％ 的值将使图像变成 3 倍亮：

img {     filter: brightness(300%); }

对比度

该滤镜控制图像的对比度。同上，它也可以接受大于或等于零的值。该滤镜控制 CSS 里图像的深色和浅色部分之间的差异。因此，值为 0％ 时的结果是得到一个灰色图像。对比度值为 100％ 则是原始图像，超过此值之后将进一步提高图像的对比度：

img { filter: contrast(0%); }

灰度

从名称上可以明显看出，该滤镜可以使你的图像变灰（黑白化）。该滤镜把所有图像的颜色转换为灰阶值。值为 0％ 时对我们的图像没有影响，值为 100％ 时会变成他们完全变成黑白，该值不允许为负。

img { filter: grayscale(100%); }

饱和度

该滤镜控制图像的饱和度。值为 0％ 时将彻底从图像中删除掉所有颜色，而当值超过 100％ 时将使图像饱和度增加。值为 100％ 时则是原始图像，该值不允许为负。

img { filter: saturate(0%); }

棕褐色化

这个滤镜会像一些老照片风格那样给图像加上深褐色色调。加入深褐色的量取决于百分比的值。值为 0％ 时则是原始图像，并当值为 100％ 时，图像将完全褐色。

img { filter: sepia(100%); }

 

色调对调

这个滤镜会把图像的所有颜色的色调对调。在该颜色对调的程度取决于指定的参数的值。当值为 0 度时，图像保持不变。虽然该滤镜没有最大值，但是，超过 360 deg 以上的值的效果会循环。也就是说，90 deg 和 450 deg 这两个值将具有相同的效果。

img { filter: hue-rotate(90deg); }

反色

这个滤镜会把图像的所有颜色反色。反色的量取决于参数的值。值为 0％ 时不会对原始图像有任何影响，当值为 100％ 时将完全反色。

img { filter: invert(100%); }

模糊

该滤镜适用于高斯模糊图像。它把每个像素的颜色涂抹在一起，并散布到邻近的边缘外围。该滤镜设置的半径参数会确定屏幕上多少的像素会连成一片，越大的值将越模糊。这个滤镜可以接受除了百分比值外的任何长度值。

img { filter: blur(1px); }

不透明度

该滤镜会将使你的图像半透明化。图像将在值为 0％ 的时候完全透明，当值为 100％ 则保持原样。该滤镜是类似于通常的 opacity 属性。这两者之间的区别只是在性能上略有差异，该滤镜在某些支持硬件加速的浏览器上会有更好的性能。

img { filter: opacity(75%); }

阴影

顾名思义，这个滤镜给图像增加了阴影效果。它基本上是一种对输入图像的 alpha 遮罩的模糊，偏移量是你指定的颜色。此属性需要 x 轴和 y 轴偏移值，以及阴影的颜色值。你也可以设置一个模糊半径值，这会决定阴影是尖锐还是模糊。

img { filter: drop-shadow(5px 5px 10px #666); }

Url()

虽然上述这些滤镜非常有用，但它们都是通用的，你的项目上可能需要更多自定义化效果。如果上述的滤镜没有满足你的需求，你可以创建自己的 SVG 滤镜并通过其 id 使用 url() 来引用这个滤镜。

  <svg style="position: absolute; top: -99999px" xmlns="http://www.w3.org/2000/svg">
<filter id="greenish">
  <feComponentTransfer>
    <feFuncR type="linear" slope="2" intercept="-0.5"/>
    <feFuncG type="linear" slope="2" intercept="-0."/>
    <feFuncB type="linear" slope="2" intercept="-0.25"/>
  </feComponentTransfer>
</filter>
<filter id="bluish">
  <feComponentTransfer>
    <feFuncR type="linear" slope="2" intercept="-0.5"/>
    <feFuncG type="linear" slope="2" intercept="-0.1"/>
    <feFuncB type="linear" slope="2" intercept="0"/>
  </feComponentTransfer>
</filter>
  </svg>

<style type="text/css">
  img {
filter: url('#greenish');
  }
  </style>

组合和动画滤镜

你也把可以多个滤镜组合在一起来创造各种效果。多数情况下，滤镜的顺序并没有多大关系，但是有的滤镜会根据在它们在你的 CSS 顺序会被其他一些滤镜将覆盖。例如，使用一个灰度滤镜后再使用深褐色滤镜最后只会出现一个棕色图像，如果顺序反过来的话会得到的一个灰度化的图像。

滤镜也可变成动画。通过正确的设置动画，你可以创建一些非常有趣的动画效果。以此为例：

img {
animation: haunted 3s infinite;
  }
 
  @keyframes haunted {
0% {
  filter: brightness(20%);
}
48% {
  filter: brightness(20%);
}
50% {
  filter: sepia(1) contrast(2) brightness(200%);
}
....
96% {
  filter: brightness(400%);
}
  }
 
在上面的代码中，具有不同值的多个滤镜会在动画的过程中生效。

 

补充

虽然滤镜会在一个元素的盒模型外描绘，但对该元素的盒子模型的几何结构没有影响。要记住滤镜会影响目标元素的一切，包括：背景，边框和文字修饰。你也可以在视频和内联框架中也使用滤镜。下面的演示说明了这个概念。更多的例子可在 Bennett Feely’s 的网站查看。

iframe

所有这些滤镜都非常伟大且性能很好，除了模糊滤镜之外，如果你的浏览器不支持硬件加速的话可能会有些慢。url() 滤镜的性能会根据你使用哪些 SVG 滤镜而决定。

filter 属性被所有主流浏览器支持。Chrome 和 Opera 需要这个属性的前缀版本一起使用。滤镜不支持 IE，不过 Edge 可以部分支持，也就是除了 url() 之外都支持。

结语

本贴给开发者探索了许多 CSS 滤镜功能。它们有很好的浏览器支持性，易于使用且比 canvas 的方案有更好的性能。此外，正如我在上面提到的，你也可以在视频以及与其他元素中使用。

如果你还有更绝妙的利用滤镜的方法，请给我留个言，或者提出你的疑问。