后端代碼
創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括泰興網(wǎng)站建設(shè)、泰興網(wǎng)站制作、泰興網(wǎng)頁制作以及泰興網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，泰興網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到泰興省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
push.php
?php
use Workerman\Worker;
require_once './Workerman/Autoloader.php';
// 初始化一個(gè)worker容器，監(jiān)聽1234端口
$worker = new Worker('websocket://0.0.0.0:1234');
// 這里進(jìn)程數(shù)必須設(shè)置為1
$worker-count = 1;
// worker進(jìn)程啟動(dòng)后建立一個(gè)內(nèi)部通訊端口
$worker-onWorkerStart = function($worker)
{
// 開啟一個(gè)內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符
$inner_text_worker = new Worker('Text://0.0.0.0:5678');
$inner_text_worker-onMessage = function($connection, $buffer)
{
global $worker;
// $data數(shù)組格式，里面有uid，表示向那個(gè)uid的頁面推送數(shù)據(jù)
$data = json_decode($buffer, true);
$uid = $data['uid'];
// 通過workerman，向uid的頁面推送數(shù)據(jù)
$ret = sendMessageByUid($uid, $buffer);
// 返回推送結(jié)果
$connection-send($ret ? 'ok' : 'fail');
};
$inner_text_worker-listen();
};
// 新增加一個(gè)屬性，用來保存uid到connection的映射
$worker-uidConnections = array();
// 當(dāng)有客戶端發(fā)來消息時(shí)執(zhí)行的回調(diào)函數(shù)
$worker-onMessage = function($connection, $data)use($worker)
{
// 判斷當(dāng)前客戶端是否已經(jīng)驗(yàn)證,既是否設(shè)置了uid
if(!isset($connection-uid))
{
// 沒驗(yàn)證的話把第一個(gè)包當(dāng)做uid（這里為了方便演示，沒做真正的驗(yàn)證）
$connection-uid = $data;
/* 保存uid到connection的映射，這樣可以方便的通過uid查找connection，
* 實(shí)現(xiàn)針對(duì)特定uid推送數(shù)據(jù)
*/
$worker-uidConnections[$connection-uid] = $connection;
return;
}
};
// 當(dāng)有客戶端連接斷開時(shí)
$worker-onClose = function($connection)use($worker)
{
global $worker;
if(isset($connection-uid))
{
// 連接斷開時(shí)刪除映射
unset($worker-uidConnections[$connection-uid]);
}
};
// 向所有驗(yàn)證的用戶推送數(shù)據(jù)
function broadcast($message)
{
global $worker;
foreach($worker-uidConnections as $connection)
{
$connection-send($message);
}
}
// 針對(duì)uid推送數(shù)據(jù)
function sendMessageByUid($uid, $message)
{
global $worker;
if(isset($worker-uidConnections[$uid]))
{
$connection = $worker-uidConnections[$uid];
$connection-send($message);
return true;
}
return false;
}
// 運(yùn)行所有的worker（其實(shí)當(dāng)前只定義了一個(gè)）
Worker::runAll();
啟動(dòng)后端服務(wù)
php push.php start -d
前端接收推送的js代碼
var ws = new WebSocket('ws://127.0.0.1:1234');
ws.onopen = function(){
var uid = 'uid1';
ws.send(uid);
};
ws.onmessage = function(e){
alert(e.data);
};
后端推送消息的代碼
// 建立socket連接到內(nèi)部推送端口
$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT);
// 推送的數(shù)據(jù)，包含uid字段，表示是給這個(gè)uid推送
$data = array('uid'='uid1', 'percent'='88%');
// 發(fā)送數(shù)據(jù)，注意5678端口是Text協(xié)議的端口，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符
fwrite($client, json_encode($data)."\n");
// 讀取推送結(jié)果
echo fread($client, 8192);
這里的uid不一定是用戶的id，也可以理解為任務(wù)id即 taskid
對(duì)于json，PHP有對(duì)應(yīng)的方法進(jìn)行操作。
一般而言，json會(huì)以字符串形式傳給PHP腳本，一般都是放在$_POST里面，
14
?php
// 接收
$json_parameter = $_POST['json_str'];
// 處理, 變成數(shù)組
$array = json_decode($json_parameter);
// PHP 把數(shù)組數(shù)據(jù)變成json格式字符串，發(fā)給頁面
$demo = array(
'key' = 'value',
'key2' = 'value2'
);
$demo_json = json_encode($demo); // 格式是{"key":"value","key2":"value2"}
echo $demo_json;
將數(shù)據(jù)轉(zhuǎn)換成 json 格式的字符串, 并通過 CURL 的 POST 的形式傳遞參數(shù)給服務(wù)端, 但是在服務(wù)端無法用 $_POST 獲取到數(shù)據(jù)。后臺(tái)用 $_POST 獲取到的信息為空, 但是可以通過 $post = file_get_contents("php://input") 獲取到請(qǐng)求的相關(guān)信息。
Coentent-Type 的值為 application/x-www-data-urlencode 和 multipart/form-data 時(shí), php才會(huì)將http請(qǐng)求數(shù)據(jù)包中的數(shù)據(jù)填進(jìn) $_POST 。
如果 POST 的原始數(shù)據(jù)是一維數(shù)組或拼接的標(biāo)準(zhǔn)格式的鍵值對(duì)字符串，那么可以用 $_POST 來獲取。
如果要通過 file_get_contents 獲取，這種情況下可以發(fā)送 json 字符串，用 json_encode 編碼轉(zhuǎn)換一下，或者使用 http_build_query 。
1、 區(qū)別 PHP 的 $_POST、$HTTP_RAW_POST_DATA 和 php://input
2、 accept 和 content-Type區(qū)別
3、 Http Header里的Content-Type
接收指定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");
// 接入點(diǎn).
IPEndPoint ephost = new IPEndPoint(localAddr, PORT);
// 第一個(gè)參數(shù)：AddressFamily = 指定 Socket 類的實(shí)例可以使用的尋址方案。
// Unspecified 未指定地址族。
// InterNetwork IP 版本 4 的地址。
// InterNetworkV6 IP 版本 6 的地址。
//
// 第二個(gè)參數(shù)：SocketType = 指定 Socket 類的實(shí)例表示的套接字類型。
// Stream 一個(gè)套接字類型，支持可靠、雙向、基于連接的字節(jié)流，而不重復(fù)數(shù)據(jù)，也不保留邊界。
// 此類型的 Socket 與單個(gè)對(duì)方主機(jī)通信，并且在通信開始之前需要建立遠(yuǎn)程主機(jī)連接。
// 此套接字類型使用傳輸控制協(xié)議 (Tcp)，AddressFamily 可以是 InterNetwork，也可以是 InterNetworkV6。
//
// 第三個(gè)參數(shù)：ProtocolType = 指定 Socket 類支持的協(xié)議。
// Tcp 傳輸控制協(xié)議 (TCP)。
Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
// 嘗試連接主機(jī).
s.Connect(ephost);
//Console.WriteLine("向服務(wù)器發(fā)送到了:{0}", SEND_MESSAGE);
// 向主機(jī)發(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ā)生了錯(cuò)誤！");
MessageBox.Show(ex.Message);
//Console.WriteLine("連接/發(fā)送/接收過程中，發(fā)生了錯(cuò)誤！");
//Console.WriteLine(ex.Message);
//Console.WriteLine(ex.StackTrace);
}
finally
{
s.Close();
}
重慶分公司
重慶分公司
