?php??
創(chuàng)新互聯(lián)堅持“要么做到,要么別承諾”的工作理念,服務(wù)領(lǐng)域包括:成都網(wǎng)站設(shè)計、做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務(wù),滿足客戶于互聯(lián)網(wǎng)時代的曹妃甸網(wǎng)站設(shè)計、移動媒體設(shè)計的需求,幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴!
/**?php?發(fā)送流文件?
*?@param??String??$url??接收的路徑?
*?@param??String??$file?要發(fā)送的文件?
*?@return?boolean?
*/??
function?sendStreamFile($url,?$file){??
if(file_exists($file)){??
$opts?=?array(??
'http'?=?array(??
'method'?=?'POST',??
'header'?=?'content-type:application/x-www-form-urlencoded',??
'content'?=?file_get_contents($file)??
)??
);??
$context?=?stream_context_create($opts);??
$response?=?file_get_contents($url,?false,?$context);??
$ret?=?json_decode($response,?true);??
return?$ret['success'];??
}else{??
return?false;??
}??
}??
$ret?=?sendStreamFile('',?'send.txt');??
var_dump($ret);??
???
?php??
/**?php?接收流文件?
*?@param??String??$file?接收后保存的文件名?
*?@return?boolean?
*/??
function?receiveStreamFile($receiveFile){??
$streamData?=?isset($GLOBALS['HTTP_RAW_POST_DATA'])??$GLOBALS['HTTP_RAW_POST_DATA']?:?'';??
if(empty($streamData)){??
$streamData?=?file_get_contents('php://input');??
}??
if($streamData!=''){??
$ret?=?file_put_contents($receiveFile,?$streamData,?true);??
}else{??
$ret?=?false;??
}??
return?$ret;??
}??
$receiveFile?=?'receive.txt';??
$ret?=?receiveStreamFile($receiveFile);??
echo?json_encode(array('success'=(bool)$ret));??
?
可以在webserver層就做反向代理。具體你可以搜索apache 反向代理?;蛘遪ginx 反向代理。
接收指定IP的數(shù)據(jù)包,其他IP都要過濾吧,那就用防火墻來搞吧
使用的是client段的獲取方式,用client的可以指定IP,代碼大概如下
public void SendMessage()
{
ASCII = Encoding.ASCII;
// 構(gòu)造用于發(fā)送的 字節(jié)緩沖.
Byte[] sendBytes = ASCII.GetBytes(SEND_MESSAGE);
// 構(gòu)造用于接收的 字節(jié)緩沖.
Byte[] recvBytes = new Byte[256];
// IP地址.
IPAddress localAddr = IPAddress.Parse("192.168.19.81");
// 接入點.
IPEndPoint ephost = new IPEndPoint(localAddr, PORT);
// 第一個參數(shù):AddressFamily = 指定 Socket 類的實例可以使用的尋址方案。
// Unspecified 未指定地址族。
// InterNetwork IP 版本 4 的地址。
// InterNetworkV6 IP 版本 6 的地址。
//
// 第二個參數(shù):SocketType = 指定 Socket 類的實例表示的套接字類型。
// Stream 一個套接字類型,支持可靠、雙向、基于連接的字節(jié)流,而不重復(fù)數(shù)據(jù),也不保留邊界。
// 此類型的 Socket 與單個對方主機通信,并且在通信開始之前需要建立遠程主機連接。
// 此套接字類型使用傳輸控制協(xié)議 (Tcp),AddressFamily 可以是 InterNetwork,也可以是 InterNetworkV6。
//
// 第三個參數(shù):ProtocolType = 指定 Socket 類支持的協(xié)議。
// Tcp 傳輸控制協(xié)議 (TCP)。
Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
// 嘗試連接主機.
s.Connect(ephost);
//Console.WriteLine("向服務(wù)器發(fā)送到了:{0}", SEND_MESSAGE);
// 向主機發(fā)送數(shù)據(jù).
// s.Send(sendBytes, sendBytes.Length, SocketFlags.None);
// 接收服務(wù)器的應(yīng)答.
Int32 bytes = s.Receive(recvBytes, recvBytes.Length, SocketFlags.None);
StringBuilder buff = new StringBuilder();
// while (bytes 0)
// {
// 將緩沖的字節(jié)數(shù)組,裝換為字符串.
// String str = ASCII.GetString(recvBytes, 0, bytes);
String str = "";
for (int i = 0; i recvBytes.Length; i++)
{
str = str + recvBytes[i];
}
int iCount = 0;
iCount = int.Parse(str.Substring(13, 6)) ;
// 加入字符串緩存
buff.Append(str);
// 再次接受,看看后面還有沒有數(shù)據(jù).
//bytes = s.Receive(recvBytes, recvBytes.Length, SocketFlags.None);
// }
textBox1.Text = iCount.ToString();
}
catch (Exception ex)
{
MessageBox.Show("連接/發(fā)送/接收過程中,發(fā)生了錯誤!");
MessageBox.Show(ex.Message);
//Console.WriteLine("連接/發(fā)送/接收過程中,發(fā)生了錯誤!");
//Console.WriteLine(ex.Message);
//Console.WriteLine(ex.StackTrace);
}
finally
{
s.Close();
}
$content?=?$_POST['data'];
$fp?=?fopen('/tmp/newfile.bin','w');
fwrite($fp,$content);
以上例子是在data參數(shù)上傳二進制,并保存到/tmp/newfile.bin中,解析json用json_decode,然后把二進制的那個值賦給content就可以
在現(xiàn)代 PHP 特性中,流或許是最出色但使用率最低的。雖然 PHP 4.3 就引入了流,但是很多開發(fā)者并不知道流的存在,因為人們很少提及流,而且流的文檔也很匱乏。PHP 官方文檔對流的解釋如下:
可能看完這段解釋后還是云里霧里,我們簡化一下,流的作用是在出發(fā)地和目的地之間傳輸數(shù)據(jù)。出發(fā)地和目的地可以是文件、命令行進程、網(wǎng)絡(luò)連接、ZIP 或 TAR 壓縮文件、臨時內(nèi)存、標準輸入或輸出,或者是通過 PHP 流封裝協(xié)議實現(xiàn)的任何其他資源。
如果你讀寫過文件,就用過流;如果你從 php://stdin 讀取過數(shù)據(jù),或者把輸入寫入 php://stdout ,也用過流。流為 PHP 的很多 IO 函數(shù)提供了底層實現(xiàn),如 file_get_contents、fopn、fread 和 fwrite 等。PHP 的流函數(shù)提供了不同資源的統(tǒng)一接口。
我們可以把流比作管道,把水(資源數(shù)據(jù))從一個地方引到另一個地方。在水從出發(fā)地到目的地的過程中,我們可以過濾水,可以改變水質(zhì),可以添加水,也可以排出水。
流式數(shù)據(jù)的種類各異,每種類型需要獨特的協(xié)議,以便讀寫數(shù)據(jù),我們稱這些協(xié)議為 流封裝協(xié)議 。例如,我們可以讀寫文件系統(tǒng),可以通過 HTTP、HTTPS 或 SSH 與遠程 Web 服務(wù)器通信,還可以打開并讀寫 ZIP、RAR 或 PHAR 壓縮文件。這些通信方式都包含下述相同的過程:
1.開始通信
2.讀取數(shù)據(jù)
3.寫入數(shù)據(jù)
4.結(jié)束通信
雖然過程是一樣的,但是讀寫文件系統(tǒng)中文件的方式與收發(fā) HTTP 消息的方式有所不同,流封裝協(xié)議的作用是使用通用的接口封裝這種差異。
每個流都有一個協(xié)議和一個目標。指定協(xié)議和目標的方法是使用流標識符:scheme://target,其中 scheme 是流的封裝協(xié)議,target 是流的數(shù)據(jù)源。
http://流封裝協(xié)議
下面使用 HTTP 流封裝協(xié)議創(chuàng)建了一個與 Flicker API 通信的 PHP 流:
不要以為這是普通的網(wǎng)頁 URL,file_get_contents() 函數(shù)的字符串參數(shù)其實是一個流標識符。http 協(xié)議會讓 PHP 使用 HTTP 流封裝協(xié)議,在這個參數(shù)中,http 之后是流的目標。
我們通常使用 file_get_contents()、fopen()、fwrite() 和 fclose() 等函數(shù)讀寫文件系統(tǒng),因為 PHP 默認使用的流封裝協(xié)議是 file://,所以我們很少認為這些函數(shù)使用的是 PHP 流。下面的示例演示了使用 file:// 流封裝協(xié)議創(chuàng)建一個讀寫 /etc/hosts 文件的流:
我們通常會省略掉 file:// 協(xié)議,因為這是 PHP 使用的默認值。
php://流封裝協(xié)議
編寫命令行腳本的 PHP 開發(fā)者會感激 php:// 流封裝協(xié)議,這個流封裝協(xié)議的作用是與 PHP 腳本的標準輸入、標準輸出和標準錯誤文件描述符通信。我們可以使用 PHP 提供的文件系統(tǒng)函數(shù)打開、讀取或?qū)懭胂旅嫠膫€流:
1. php://stdin :這是個只讀 PHP 流,其中的數(shù)據(jù)來自標準輸入。PHP 腳本可以使用這個流接收命令行傳入腳本的信息;
2. php://stdout :把數(shù)據(jù)寫入當前的輸出緩沖區(qū),這個流只能寫,無法讀或?qū)ぶ罚?/p>
3. php://memory :從系統(tǒng)內(nèi)存中讀取數(shù)據(jù),或者把數(shù)據(jù)寫入系統(tǒng)內(nèi)存。缺點是系統(tǒng)內(nèi)存有限,所有使用 php://temp 更安全;
4. php://temp :和 php://memory 類似,不過,沒有可用內(nèi)存時,PHP 會把數(shù)據(jù)寫入這個臨時文件。
其他流封裝協(xié)議
PHP 和 PHP 擴展還提供了很多其他流封裝協(xié)議,例如,與 ZIP 和 TAR 壓縮文件、FTP 服務(wù)器、數(shù)據(jù)壓縮庫、Amazon API、Dropbox API 等通信的流封裝協(xié)議。需要注意的是,PHP 中的 fopen()、fgets()、fputs()、feof() 以及 fclose() 等函數(shù)不僅可以用來處理文件系統(tǒng)中的文件,還可以在所有支持這些函數(shù)的流封裝協(xié)議中使用。
自定義流封裝協(xié)議
我們還可以自己編寫 PHP 流封裝協(xié)議。PHP 提供了一個示例 StreamWrapper 類,演示如何編寫自定義的流封裝協(xié)議,支持部分或全部 PHP 文件系統(tǒng)函數(shù)。關(guān)于如何編寫,具體請參考以下文檔:
有些 PHP 流能夠接受一系列可選的參數(shù),這些參數(shù)叫流上下文,用于定制流的行為。不同的流封裝協(xié)議使用的流上下文有所不同,流上下文使用 stream_context_create() 函數(shù)創(chuàng)建,這個函數(shù)返回的上下文對象可以傳入大多數(shù)文件系統(tǒng)函數(shù)。
例如,你知道可以使用 file_get_contents() 發(fā)送 HTTP POST 請求嗎?使用一個流上下文對象即可實現(xiàn):
流過濾器
目前為止我們討論了如何打開流,讀取流中的數(shù)據(jù),以及把數(shù)據(jù)寫入流。不過,PHP 流真正強大的地方在于過濾、轉(zhuǎn)換、添加或刪除流中傳輸?shù)臄?shù)據(jù),例如,我們可以打開一個流處理 Markdown 文件,在把文件內(nèi)容讀入內(nèi)存的過程中自動將其轉(zhuǎn)化為 HTML。
運行該腳本,輸出的都是大寫字母:
我們還可以使用 php://filter 流封裝協(xié)議把過濾器附加到流上,不過,使用這種方式之前必須先打開 PHP 流:
這個方式實現(xiàn)效果和 stream_filter_append() 函數(shù)一樣,但是相比之下更為繁瑣。不過,PHP 的某些文件系統(tǒng)函數(shù)在調(diào)用后無法附加過濾器,例如 file() 和 fpassthru(),使用這些函數(shù)時只能使用 php://filter 流封裝協(xié)議附加流過濾器。
自定義流過濾器
我們還可以編寫自定義的流過濾器。其實,大多數(shù)情況下都要使用自定義的流過濾器,自定義的流過濾器是個 PHP 類,繼承內(nèi)置的 php_user_filter 類( ),且必須實現(xiàn) filter()、onCreate() 和 onClose() 方法,最后,必須使用 stream_filter_register() 函數(shù)注冊自定義的流過濾器。
然后,我們必須使用 stream_filter_register() 函數(shù)注冊這個自定義的 DirtyWordsFilter 流過濾器:
第一個參數(shù)用于標識這個自定義過濾器的過濾器名,第二個參數(shù)是這個自定義過濾器的類名。接下來就可以使用這個自定義的流過濾器了:
修改 test.txt 內(nèi)容如下:
運行上面的自定義過濾器腳本,結(jié)果如下:
stream_bucket_append函數(shù):為隊列添加數(shù)據(jù)
stream_bucket_make_writeable函數(shù):從操作的隊列中返回一個數(shù)據(jù)對象
stream_bucket_new函數(shù):為當前隊列創(chuàng)建一個新的數(shù)據(jù)
stream_bucket_prepend函數(shù):預(yù)備數(shù)據(jù)到隊列
stream_context_create函數(shù):創(chuàng)建數(shù)據(jù)流上下文
stream_context_get_default函數(shù):獲取默認的數(shù)據(jù)流上下文
stream_context_get_options函數(shù):獲取數(shù)據(jù)流的設(shè)置
stream_context_set_option函數(shù):對數(shù)據(jù)流、數(shù)據(jù)包或者上下文進行設(shè)置
stream_context_set_params函數(shù):為數(shù)據(jù)流、數(shù)據(jù)包或者上下文設(shè)置參數(shù)
stream_copy_to_stream函數(shù):在數(shù)據(jù)流之間進行復(fù)制操作
stream_filter_append函數(shù):為數(shù)據(jù)流添加過濾器
stream_filter_prepend函數(shù):為數(shù)據(jù)流預(yù)備添加過濾器
stream_filter_register函數(shù):注冊一個數(shù)據(jù)流的過濾器并作為PHP類執(zhí)行
stream_filter_remove函數(shù):從一個數(shù)據(jù)流中移除過濾器
stream_get_contents函數(shù):讀取數(shù)據(jù)流中的剩余數(shù)據(jù)到字符串
stream_get_filters函數(shù):返回已經(jīng)注冊的數(shù)據(jù)流過濾器列表
stream_get_line函數(shù):按照給定的定界符從數(shù)據(jù)流資源中獲取行
stream_get_meta_data函數(shù):從封裝協(xié)議文件指針中獲取報頭/元數(shù)據(jù)
stream_get_transports函數(shù):返回注冊的Socket傳輸列表
stream_get_wrappers函數(shù):返回注冊的數(shù)據(jù)流列表
stream_register_wrapper函數(shù):注冊一個用PHP類實現(xiàn)的URL封裝協(xié)議
stream_select函數(shù):接收數(shù)據(jù)流數(shù)組并等待它們狀態(tài)的改變
stream_set_blocking函數(shù):將一個數(shù)據(jù)流設(shè)置為堵塞或者非堵塞狀態(tài)
stream_set_timeout函數(shù):對數(shù)據(jù)流進行超時設(shè)置
stream_set_write_buffer函數(shù):為數(shù)據(jù)流設(shè)置緩沖區(qū)
stream_socket_accept函數(shù):接受由函數(shù)stream_ socket_server()創(chuàng)建的Socket連接
stream_socket_client函數(shù):打開網(wǎng)絡(luò)或者UNIX主機的Socket連接
stream_socket_enable_crypto函數(shù):為一個已經(jīng)連接的Socket打開或者關(guān)閉數(shù)據(jù)加密
stream_socket_get_name函數(shù):獲取本地或者網(wǎng)絡(luò)Socket的名稱
stream_socket_pair函數(shù):創(chuàng)建兩個無區(qū)別的Socket數(shù)據(jù)流連接
stream_socket_recvfrom函數(shù):從Socket獲取數(shù)據(jù),不管其連接與否
stream_socket_sendto函數(shù):向Socket發(fā)送數(shù)據(jù),不管其連接與否
stream_socket_server函數(shù):創(chuàng)建一個網(wǎng)絡(luò)或者UNIX Socket服務(wù)端
stream_wrapper_restore函數(shù):恢復(fù)一個事先注銷的數(shù)據(jù)包
stream_wrapper_unregister函數(shù):注銷一個URL地址包
整合資料
本文整合于以下兩篇文章
網(wǎng)站名稱:php轉(zhuǎn)發(fā)數(shù)據(jù)流,php上傳數(shù)據(jù)庫
網(wǎng)站URL:http://m.kartarina.com/article24/hsdpce.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站內(nèi)鏈、微信公眾號、外貿(mào)網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)、品牌網(wǎng)站制作、品牌網(wǎng)站設(shè)計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)