安卓+php推,使用 PHP 消息队列实现 Android 与 Web 通信
需求描述很簡(jiǎn)單：Android 發(fā)送數(shù)據(jù)到 Web 網(wǎng)頁(yè)上。
系統(tǒng)： Ubuntu 14.04 + apache2 + php5 + Android 4.4
思路是 socket + 消息隊(duì)列 + 服務(wù)器發(fā)送事件，下面的講解步驟為 Android 端，服務(wù)器端，前端。重點(diǎn)是在于 PHP 進(jìn)程間通信。
Android 端比較直接，就是一個(gè) socket 程序。需要注意的是，如果直接在活動(dòng)主線程里面創(chuàng)建 socket 會(huì)報(bào)一個(gè) android.os.NetworkOnMainThreadException， 因此最好的方法是開(kāi)個(gè)子線程來(lái)創(chuàng)建 socket，代碼如下
private Socket socket = null;
private boolean connected = false;
private PrintWriter out;
private BufferedReader br;
private void buildSocket(){
if(socket != null)
return;
try {
socket = new Socket("223.3.68.101",54311); //IP地址與端口號(hào)
out = new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socket.getOutputStream())), true);
br = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
}
connected = true;
}
然后是發(fā)送消息
public void sendMsg(String data){
if(!connected || socket == null) return;
synchronized (socket) {
try {
out.println(data);
} catch (Exception e) {
e.printStackTrace();
}
}
}
完成后還需要關(guān)閉 socket
private void closeSocket(){
if( socket == null) return;
try {
socket.close();
out.close();
br.close();
} catch (IOException e) {
e.printStackTrace();
}
socket = null;
connected = false;
}
注意這些方法都不要在主線程執(zhí)行。
下面是服務(wù)器 PHP 端。
首先要運(yùn)行一個(gè)進(jìn)程來(lái)接收信息。
function buildSocket($msg_queue){
$address = "223.3.68.101";
$port = 54321;
if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false){
echo "socket_create() failed:" . socket_strerror(socket_last_error()) . "/n";
die;
}
echo "socket create\n";
if (socket_set_block($sock) == false){
echo "socket_set_block() faild:" . socket_strerror(socket_last_error()) . "\n";
die;
}
if (socket_bind($sock, $address, $port) == false){
echo "socket_bind() failed:" . socket_strerror(socket_last_error()) . "\n";
die;
}
if (socket_listen($sock, 4) == false){
echo "socket_listen() failed:" . socket_strerror(socket_last_error()) . "\n";
die;
}
echo "listening\n";
if (($msgsock = socket_accept($sock)) === false) {
echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
die;
}
$buf = socket_read($msgsock, 8192);
while(true){
if(strlen($buf) > 1)
handleData($buf,$msg_queue); //見(jiàn)后文
$buf = socket_read($msgsock, 8192);
//看情況 break 掉
}
socket_close($msgsock);
}
也比較簡(jiǎn)單。這個(gè)進(jìn)程是獨(dú)立運(yùn)行的，那么打開(kāi)網(wǎng)頁(yè)請(qǐng)求數(shù)據(jù)，需要從另一段腳本接入，下面就需要用到進(jìn)程間通信，我選擇消息隊(duì)列，也就是上面的 $msg_queue 變量。
腳本主程序這么寫。
$msg_queue_key = ftok(__FILE__,'socket'); //__FILE__ 指當(dāng)前文件名字
$msg_queue = msg_get_queue($msg_queue_key); //獲取已有的或者新建一個(gè)消息隊(duì)列
buildSocket($msg_queue);
socket_close($sock);
其中的 ftok() 函數(shù)就是生成一個(gè)隊(duì)列的 key，以區(qū)分。
那么handleData() 的任務(wù)就是把收到的消息放到隊(duì)列里面去
function handleData($dataStr, $msg_queue){
msg_send($msg_queue,1,$dataStr);
}
Socket 進(jìn)程腳本骨架
這樣一來(lái)，其他進(jìn)程就可以通過(guò) key 找到這個(gè)隊(duì)列，從里面讀取消息了。使用這樣可讀
function redFromQueue($message_queue){
msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
echo $message."\n\n";
}
$msg_queue_key = ftok("socket.php", 'socket'); //第一個(gè)變量為上方socket進(jìn)程的文件名。
$msg_queue = msg_get_queue($msg_queue_key, 0666);
while(true){
$msg_queue_status = msg_stat_queue($msg_queue); //獲取消息隊(duì)列的狀態(tài)
if($msg_queue_status["msg_qnum"] == 0) //如果此時(shí)消息隊(duì)列為空，那么跳過(guò)，否則會(huì)讀取空行。
continue;
redFromQueue($msg_queue);
}
現(xiàn)在就差最后一步，如何主動(dòng)把數(shù)據(jù)發(fā)往前端？這要用到 HTML5 的新特性：服務(wù)器發(fā)送事件(要使用較新的非 IE 瀏覽器，具體查看這里)。直接看JS代碼
var source = new EventSource("php/getData.php"); //Web 服務(wù)器路徑
source.onmessage = function(event){ //消息事件回調(diào)
var resData = event.data;
document.getElementById("res").innerHTML=resData;
};
那么這個(gè) getData.php 就是上面那個(gè)從消息隊(duì)列獲取數(shù)據(jù)的腳本。只是為了讓它被識(shí)別為服務(wù)器事件，需要加一點(diǎn)格式上的說(shuō)明，具體如下。
下面就可以開(kāi)始運(yùn)行，首先運(yùn)行服務(wù)器
php socket.php
打印了 listening 就可以使用 Android 設(shè)備連接了。
然后再用 Web 上 JS 請(qǐng)求 getData 腳本，請(qǐng)求后前臺(tái)可以不斷地獲得新的數(shù)據(jù)。需要注意的是消息隊(duì)列可能會(huì)阻塞(消息量達(dá)到上限)，再有就是 JS 本身消息機(jī)制的限制，因此丟失，延遲等現(xiàn)象頻發(fā)。
Web 通信的老問(wèn)題就是穩(wěn)定性。以前老是怨恨 Web QQ 掉包，其實(shí)整個(gè) Web 革命尚未成功。
希望與廣大網(wǎng)友互動(dòng)？？
點(diǎn)此進(jìn)行留言吧！
總結(jié)
以上是生活随笔為你收集整理的安卓+php推,使用 PHP 消息队列实现 Android 与 Web 通信的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 多版本php共存 linux,linux
- 下一篇： PHP artisan auth,Php