基于Tor socks5的http消息类

更新时间：2016年11月25日 15:56 点击：1713

try{
    $tor = new TorHttp('127.0.0.1', 9050);
    $data = array('username' => 'liujun');
    $headers = array('Cookie' => 'php教程id=123456; xx=v');
    echo $tor->get('http://host.com/testsocks.php', $headers);
    $tor->newId('123456');
}catch(Exception $e){
    if($e->getCode() == 9999){
        $tor->newId('123456');
    }
    echo $e->getMessage() . "n";
}
*/

class Tool_TorHttp
{
 /**
 * Tor提供的socks服务器
 *
 * @var <string
 */
 private $_host;

/**
 * socks服务的连接
 *
 * @var <stream>
 */
 private $_sock;

/**
 * 构造函数
 *
 * @param <string> $host socks服务器地址
 * @param <int> $port
 */
 public function __construct($host = '127.0.0.1', $port = 9050)
 {
 $this->_host = $host;
 @ $this->_sock = fsockopen($host, $port, $errorCode, $error, 5);

        if($errorCode){
           throw new Exception('不能连接代理服务器');
        }

        //建立应用层的连接
        fwrite($this->_sock, pack('C3', 5, 1, 0));
        $resp = fread($this->_sock, 1024);
        $resp = unpack('Cversion/Cmethod', $resp);
        if($resp['version'] != 5 || $resp['method'] != 0){
            $this->_sock = null;
            throw new Exception('代理服务器不可用或者需要连接密码');
        }
    }

/**
 * 连接目标主机
 *
 * @param <type> $host
 * @param <type> $port
 */
 private function _connect($host, $port)
 {
 //ip和域名描述的服务器用不同的报文格式
 $lip = ip2long($host);
 if(empty($lip)){
 $pack = pack('C5', 5, 1, 0, 3, strlen($host)) . $host . pack('n', intval($port));
 }else{
 $pack = pack('C4Nn', 5, 1, 0, 1, $lip, $port);
 }
 fwrite($this->_sock, $pack);
 $resp = '';
 $counter = 0;
 while(true){
 if(feof($this->_sock)){
 break;
 }
 $resp .= fread($this->_sock, 1024);
 if(!empty($resp) || $counter == 50){
 break;
 }
 $counter += 1;
 }

        $resp = unpack('Cversion/Crep', $resp);
        if(($resp['version'] != 5) || ($resp['rep'] != 0)){
            throw new Exception("请求的服务[$host:$port]暂时不可用，或者Tor不能到达，如果反复发生，请尝试重启Tor", 9999);
        }
    }

/**
 * 发起一次http的get请求
 *
 * @param <type> $url
 * @return <string>
 */
 public function get($url, $headers = array())
 {
 $ua = parse_url($url);
 if(empty($ua['port'])){
 $ua['port'] = 80;
 }

$this->_connect($ua['host'], $ua['port']);

$requestUri = $ua['path'];

        if(!empty($ua['query'])){
                $requestUri .= '?' . $ua['query'];
        }

        $headers['Host'] = $ua['host'];
        if(!isset($headers['User-Agent'])){
            $headers['User-Agent'] = "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9.0.10) Gecko/2009042316 Firefox/3.0.10 GTB5";
        }
        $headers['Connection'] = 'close';

        fwrite($this->_sock, "GET {$requestUri} HTTP/1.1n");
        foreach ($headers as $key => $val){
            fwrite($this->_sock, "{$key}: {$val}n");
        }
        fwrite($this->_sock, "n");

        $resp = '';
        while(!feof($this->_sock)){
            $resp .= fread($this->_sock, 1024);
        }
        return $resp;
    }

/**
 * 发起一次http的post请求
 *
 * @param <type> $url
 * @param <type> $data
 * @param <type> $headers
 * @return <type>
 */
 public function post($url, $data, $headers = array())
 {
 $ua = parse_url($url);

        if(empty($ua['port'])){
            $ua['port'] = 80;
        }

$this->_connect($ua['host'], $ua['port']);

        if(isset($ua['path']) && !empty($ua['path'])){
            $requestUri = $ua['path'];
        }else{
            $requestUri = '/';
        }

        if(!empty($ua['query'])){
            $requestUri .= '?' . $ua['query'];
        }

        if(!isset($headers['User-Agent'])){
            $headers['User-Agent'] = "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9.0.10) Gecko/2009042316 Firefox/3.0.10 GTB5";
        }
        $headers['Connection'] = 'close';

$data = $this->_parseData($data);

        fwrite($this->_sock, "POST {$requestUri} HTTP/1.1n");
        fwrite($this->_sock, "Host: {$ua['host']}n");
        fwrite($this->_sock, "Content-Type: application/x-www-form-urlencodedn");
        fwrite($this->_sock, "Content-Length: " . strlen($data) . "n");
        foreach ($headers as $key => $val){
            fwrite($this->_sock, "{$key}: {$val}n");
        }
        fwrite($this->_sock, "n");
        fwrite($this->_sock, $data . "n");

        $resp = '';
        while(!feof($this->_sock)){
            $resp .= fread($this->_sock, 1024);
        }
        return $resp;
    }

/**
 * 更新Tor的身份
 *
 * @param <type> $password
 * @param <type> $port
 * @return <type>
 */
 public function newId($password = '', $port = 9051)
 {
 if(!empty($password) && $password[0] != '"'){
 $password = '"' . $password . '"';
 }

        //创建到tor控终端的连接
        @ $sock = fsockopen($this->_host, $port, $errorCode, $error, 5);
        if($errorCode){
           throw new Exception('不能连接代理服务器控制端，请检查端口号');
        }

        fwrite($sock, "AUTHENTICATE {$password}n");
        $resp = fread($sock, 1024);
        if(!preg_match('/^250/', $resp)){
            throw new Exception('Tor控制认证失败，请确认密码正确');
        }

        fwrite($sock, "SIGNAL NEWNYMn");
        $resp = fread($sock, 1024);
        if(!preg_match('/^250/', $resp)){
            throw new Exception('更新身份失败，请重试');
        }
        return true;
    }

    private function _parseData($data)
    {
        if(empty($data) || !is_array($data)){
                return $data;
        }
        $encoded = '';
        while (list($k, $v) = each($data)) {
            $encoded .= $k . "=" . $v . '&';
        }
        return substr($encoded, 0, -1);
    }

    public function __destruct()
    {
        fclose($this->_sock);
        $this->_sock = null;
    }
}

方法一
<?php教程
echo strtotime('last Monday');
echo ' ';
echo strtotime('next Sunday');
?>

方法二
<?

02 function getMonSun(){

03 $curTime=time();

05 $curWeekday = date('w');

07 //为0是就是星期七

08 $curWeekday = $curWeekday?$curWeekday:7;

11 $curMon = $curTime - ($curWeekday-1)*86400;

12 $curSun = $curTime + (7 - $curWeekday)*86400;

14 $cur['Mon'] = $curMon;

15 $cur['Sun'] = $curSun;

17 return $cur;

18 }

19 $cur = getMonSun();

21 echo date('Y-m-d',$cur['Mon']);

22 echo "rn";

23 echo date('Y-m-d',$cur['Sun']);

24 ?>

方法三

02 function getMonSun(){

03 $curTime=time();

05 //求出当前是星期几：

06 $curWeekday = date('w');

08 //如果是周一则减上7*86400周二减上6*86400，依此类推得到周一的时间戳：

09 switch ($curWeekday) {

10 case 0:

11 $curMon = $curTime-7*86400;

12 $curSun = $curTime;

13 break;

14 case 1:

15 $curMon = $curTime;

16 $curSun = $curTime+6*86400;

17 break;

18 case 2:

19 $curMon = $curTime-1*86400;

20 $curSun = $curTime+5*86400;

21 break;

22 case 3:

23 $curMon = $curTime-2*86400;

24 $curSun = $curTime+4*86400;

25 break;

26 case 4:

27 $curMon = $curTime-3*86400;

28 $curSun = $curTime+3*86400;

29 break;

30 case 5:

31 $curMon = $curTime-4*86400;

32 $curSun = $curTime+2*86400;

33 break;

34 case 6:

35 $curMon = $curTime-5*86400;

36 $curSun = $curTime+1*86400;

37 break;

38 }

39 $cur['Mon'] = $curMon;

40 $cur['Sun'] = $curSun;

42 return $cur;

43 }

44 $cur = getMonSun();

45 echo date('Y-m-d',$cur['Mon']);

46 echo "rn";

47 echo date('Y-m-d',$cur['Sun']);

48 ?>

其实于php file_exists 函数与 file_exists语法我们早就讲过了，下面我们来看看一下关于它的使用方法与实例吧

bool file_exists ( string filename )

如果由 filename 指定的文件或目录存在则返回 TRUE，否则返回 FALSE。

其实于php教程 file_exists 函数与 file_exists语法我们早就讲过了，下面我们来看看一下关于它的使用方法与实例吧

路径的文件或目录。

在Windows上，使用/ /计算机名/共享/文件名或计算机名共享文件名，以检查网络共享文件。

这是一个很简单的实例一

<?php
$filename = '/www.111cn.net/aa/to/foo.txt';

if (file_exists($filename)) {
echo "文件$filename exists";
} else {
echo "文件$filename 不存在";
}
?>

输出结果为:

文件/www.111cn.net/aa/to/foo.txt己存在

再来看看实例二

<?php
echo file_exists("www.111cn.net.txt");
?>

这个我们就直接用file_exists来返回ture or false

PHP程序的缓冲，而不论PHP执行在何种情况下（CGI ，web服务器等等）。该函数将当前为止程序的所有输出发送到用户的浏览器。
flush() 函数不会对服务器或客户端浏览器的缓存模式产生影响。因此，必须同时使用 ob_flush() 和flush() 函数来刷新输出缓冲。
个别web服务器程序，特别是Win32下的web服务器程序，在发送结果到浏览器之前，仍然会缓存脚本的输出，直到程序结束为止

*/
for ($i=10; $i>0; $i--)
{
echo $i;
ob_flush();
flush();
sleep(1);
}

// Microsoft Internet Explorer 只有当接受到的256个字节以后才开始显示该页面，所以必须发送一些额外的空格来让这些浏览器显示页面内容

//正常用法

ob_start();
ob_end_flush();
for($i = 1; $i <= 300; $i++ )echo ' www.111cn.net';

$i = 0;
while(1) {
echo $i;
sleep(1);
$i++;
}

for($i=0;$i<10;$i++) {
 echo $i;
 flush();
 sleep(1);
}

//这段代码，应该隔一秒钟输出一次$i,但是实际中却不一定是这样,IE浏览器下有可能是等了10秒钟后,所有的输出同时呈现出来

//ob_end_flush();//IE8下没起作用
echo str_pad(" ", 256);//IE需要接受到256个字节之后才开始显示

for($i=0;$i<18;$i++) {
 echo $i;
 flush();
 sleep(1);
}

<?xml version="1.0" encoding="gb2312"?>
<rss version="2.0">
<channel>
<title>javascript教程</title>
<link>http://blog.111cn.net/zhongmao/category/29515.asp教程x</link>
<description>javascript</description>
<language>zh-chs</language>
<generator>.text version 0.958.2004.2001</generator>
<item>
<creator>zhongmao</creator>
<title orderby="1">out put excel used javascript</title>
<link>http://blog.111cn.net/zhongmao/archive/2004/09/15/105385.aspx</link>
<pubdate>wed, 15 sep 2004 13:32:00 gmt</pubdate>
<guid>http://blog.111cn.net/zhongmao/archive/2004/09/15/105385.aspx</guid>
<comment>http://blog.111cn.net/zhongmao/comments/105385.aspx</comment>
<comments>http://blog.111cn.net/zhongmao/archive/2004/09/15/105385.aspx#feedback</comments>
<comments>2</comments>
<commentrss>http://blog.111cn.net/zhongmao/comments/commentrss/105385.aspx</commentrss>
<ping>http://blog.111cn.net/zhongmao/services/trackbacks/105385.aspx</ping>
<description>test description</description>
</item>
<item>
<creator>zhongmao</creator>
<title orderby="2">out put word used javascript</title>
<link>http://blog.111cn.net/zhongmao/archive/2004/08/06/67161.aspx</link>
<pubdate>fri, 06 aug 2004 16:33:00 gmt</pubdate>
<guid>http://blog.111cn.net/zhongmao/archive/2004/08/06/67161.aspx</guid>
<comment>http://blog.111cn.net/zhongmao/comments/67161.aspx</comment>
<comments>http://blog.111cn.net/zhongmao/archive/2004/08/06/67161.aspx#feedback</comments>
<comments>0</comments>
<commentrss>http://blog.111cn.net/zhongmao/comments/commentrss/67161.aspx</commentrss>
<ping>http://blog.111cn.net/zhongmao/services/trackbacks/67161.aspx</ping>
<description>test word description</description>
</item>
<item>
<creator>zhongmao</creator>
<title orderby="3">xmlhttp</title>
<link>http://blog.111cn.net/zhongmao/archive/2004/08/02/58417.aspx</link>
<pubdate>mon, 02 aug 2004 10:11:00 gmt</pubdate>
<guid>http://blog.111cn.net/zhongmao/archive/2004/08/02/58417.aspx</guid>
<comment>http://blog.111cn.net/zhongmao/comments/58417.aspx</comment>
<comments>http://blog.111cn.net/zhongmao/archive/2004/08/02/58417.aspx#feedback</comments>
<comments>0</comments>
<commentrss>http://blog.111cn.net/zhongmao/comments/commentrss/58417.aspx</commentrss>
<ping>http://blog.111cn.net/zhongmao/services/trackbacks/58417.aspx</ping>
<description>xmlhttpaaa asd bb cc dd</description>
</item>
</channel>
</rss>
<?

//首先要创建一个DOMDocument对象
$dom = new DomDocument();
//然后载入XML文件
$dom -> load("test.xml");

//输出XML文件
//header("Content-type: text/xml;charset=gb2312");
//echo $dom -> saveXML();

//保存XML文件，返回值为int（文件大小，以字节为单位）
//$dom -> save("newfile.xml");

echo "<hr/>取得所有的title元素:<hr/>";
$titles = $dom -> getElementsByTagName("title");
foreach ($titles as $node){
echo $node -> textContent . " ";
//这样也可以
//echo $node->firstChild->data . " ";
}

/*
echo "<hr/>从根结点遍历所有结点： ";
foreach ($dom->documentElement->childNodes as $items) {
//如果节点是一个元素(nodeType == 1)并且名字是item就继续循环
if ($items->nodeType == 1 && $items->nodeName == "item") {
foreach ($items->childNodes as $titles) {
//如果节点是一个元素，并且名字是title就打印它.
if ($titles->nodeType == 1 && $titles->nodeName == "title") {
print $titles->textContent . "n";
}
}
}
}
*/

//使用XPath查询数据
echo "<hr/>使用XPath查询的title节点结果:<hr/>";
$xpath = new domxpath($dom);
$titles = $xpath->query("/rss/channel/item/title");
foreach ($titles as $node){
echo $node->textContent." ";
}
/*
这样和使用getElementsByTagName()方法差不多，但是Xpath要强大的多
深入一点可能是这样：
/rss/channel/item[position() = 1]/title 返回第一个item元素的所有
/rss/channel/item/title[@id = '23'] 返回所有含有id属性并且值为23的title
/rss/channel/&folder&/title 返回所有articles元素下面的title(译者注：&folder&代表目录深度)
*/

//向DOM中写入新数据
$item = $dom->createElement("item");
$title = $dom->createElement("title");
$titleText = $dom->createTextNode("title text");
$title->appendChild($titleText);
$item->appendChild($title);
$dom->documentElement->getElementsByTagName('channel')->item(0)->appendChild($item);

//从DOM中删除节点
//$dom->documentElement->RemoveChild($dom->documentElement->getElementsByTagName("channel")->item(0));
//或者使用xpath查询出节点再删除
//$dom->documentElement->RemoveChild($xpath->query("/rss/channel")->item(0));
//$dom->save("newfile.xml");

//从DOM中修改节点数据
//修改第一个title的文件
//这个地方比较笨，新创建一个节点，然后替换旧的节点。如果哪位朋友有其他好的方法请一定要告诉我
$firstTitle = $xpath->query("/rss/channel/item/title")->item(0);
$newTitle = $dom->createElement("title");
$newTitle->appendChild(new DOMText("This's the new title text!!!"));
$firstTitle->parentNode->replaceChild($newTitle, $firstTitle);
//修改属性
//$firstTitle = $xpath->query("/rss/channel/item/title")->item(0);
//$firstTitle->setAttribute("orderby", "4");
$dom->save("newfile.xml");

echo "<hr/><a href="newfile.xml">查看newfile.xml</a>";

//下面的代码获得并解析111cn.net的首页，将返第一个title元素的内容。
/*
$dom->loadHTMLFile("http://www.111cn.net/");
$title = $dom->getElementsByTagName("title");
print $title->item(0)->textContent;
*/
?>

[!--infotagslink--]

上一篇: 多种移动手机号码正则表达式验证代码

下一篇: php file_exists 函数与 file_exists语法

C#实现简单的Http请求实例
这篇文章主要介绍了C#实现简单的Http请求的方法,以实例形式较为详细的分析了C#实现Http请求的具体方法,需要的朋友可以参考下...2020-06-25
Java如何发起http请求的实现(GET/POST)
这篇文章主要介绍了Java如何发起http请求的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-03-31
C#实现HTTP下载文件的方法
这篇文章主要介绍了C#实现HTTP下载文件的方法,包括了HTTP通信的创建、本地文件的写入等,非常具有实用价值,需要的朋友可以参考下...2020-06-25
C#使用Http Post方式传递Json数据字符串调用Web Service
这篇文章主要为大家详细介绍了C#使用Http Post方式传递Json数据字符串调用Web Service，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2020-06-25
解决Feign切换client到okhttp无法生效的坑(出现原因说明)
这篇文章主要介绍了解决Feign切换client到okhttp无法生效的坑(出现原因说明)，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-25
完美解决SpringCloud-OpenFeign使用okhttp替换不生效问题
这篇文章主要介绍了完美解决SpringCloud-OpenFeign使用okhttp替换不生效问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-25
解决Java处理HTTP请求超时的问题
这篇文章主要介绍了解决Java处理HTTP请求超时的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-29
C#微信开发之发送模板消息
这篇文章主要为大家详细介绍了C#微信开发之发送模板消息的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2020-06-25
HTTP 415错误-Unsupported media type详解
这篇文章主要介绍了HTTP 415错误-Unsupported media type详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下...2021-08-16
Angular利用HTTP POST下载流文件的步骤记录
这篇文章主要给大家介绍了关于Angular利用HTTP POST下载流文件的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者使用Angular具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧...2020-07-26
WM_CLOSE、WM_DESTROY、WM_QUIT及各种消息投递函数详解
这篇文章主要介绍了WM_CLOSE、WM_DESTROY、WM_QUIT及各种消息投递函数,有助于读者更好的理解windows程序的消息机制,需要的朋友可以参考下...2020-04-25
详解nginx同一端口监听多个域名和同时监听http与https
这篇文章主要介绍了详解nginx同一端口监听多个域名和同时监听http与https的相关资料,需要的朋友可以参考下...2017-07-06
Node.js之http模块的用法
这篇文章主要介绍了Node.js之http模块的用法，对Node.js感兴趣的同学，可以参考下...2021-04-25
微信小程序封装http访问网络库实例代码
这篇文章主要介绍了微信小程序封装http访问网络库实例代码的相关资料,需要的朋友可以参考下...2017-05-27
快速学习AngularJs HTTP响应拦截器
任何时候，如果我们想要为请求添加全局功能，例如身份认证、错误处理等，在请求发送给服务器之前或服务器返回时对其进行拦截，是比较好的实现手段...2016-01-05
简单用VBS调用企业微信机器人发定时消息的方法
这篇文章主要介绍了简单用VBS调用企业微信机器人发定时消息的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2020-12-08
python实现企业微信定时发送文本消息的实例代码
这篇文章主要介绍了python实现企业微信定时发送文本消息的实例代码,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下...2020-11-25
C#处理和对接HTTP接口请求的方法
下面通过四步给大家介绍了c#处理和对接http接口请求的方法，分步骤介绍的非常详细，具有参考借鉴价值，感兴趣的朋友一起看下吧...2020-06-25
解决golang处理http response碰到的问题和需要注意的点
这篇文章主要介绍了解决golang处理http response碰到的问题和需要注意的点，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-16
jquery插件jquery.confirm弹出确认消息
这篇文章介绍了插件jquery.confirm弹出确认消息的实现方法，感兴趣的小伙伴们可以参考一下...2015-12-24

基于Tor socks5的http消息类

相关文章

阁下可能感兴趣的内容

推荐阅读