我想问如何创建一个能够实时接收android手机请求的PHP套接字?目前,我已经完成了这部分代码,并能够使用telnet进行测试。然而,当安卓手机尝试连接时,它无法接收或向服务器发送任何内容。
if (!defined('SOCKET_ADDRESS')) {
define('SOCKET_ADDRESS', '192.168.1.4');
}
if (!defined('SOCKET_PORT')) {
define('SOCKET_PORT', '5888');
}
if (!defined('MAX_CLIENTS')) {
define('MAX_CLIENTS', '10');
}
set_time_limit(0);
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($socket, SOCKET_ADDRESS, SOCKET_PORT) or die('Could not bind to address ' . SOCKET_ADDRESS . ' on port ' . SOCKET_PORT . "!'n");
socket_listen($socket, MAX_CLIENTS) or die("Could not setup socket listener!'n");
// setup read socket array
$read = array();
// client array w/ default initial socket
$clients = array('0' => array('socket' => $socket));
// force debug at first run..
$debug = true;
$time = time();
printf('Time: %d%s', $time, "'n");
$status = true;
while ($status) {
if (time() - $time >= 10) {
$time = time();
printf('Time: %d%s', $time, "'n");
$debug = true;
}
if ($debug === true) {
printf('Debug: %s%s', $debug, "'n");
}
// $read[0] = $socket;
if ($debug) {
var_dump($read);
}
// Handle clients
for ($i = 0; $i < count($clients); $i++) {
if (isset($clients[$i]['socket'])) {
if ($debug === true) {
printf('Setting socket %d to client %d%s', $i, $i, "'n");
}
$read[$i] = $clients[$i]['socket'];
}
}
if ($debug) {
var_dump($read);
}
// Any changed sockets?
// $write and $except are only placeholders
$changed_sockets = socket_select($read, $write = NULL, $except = NULL, 0);
if ($debug === true) {
printf('Changed sockets: %d%s', $changed_sockets, "'n");
}
// Handle new connections
if (in_array($socket, $read)) {
for ($i = 0; $i < MAX_CLIENTS; $i++) {
if (!isset($clients[$i])) {
$clients[$i]['socket'] = socket_accept($socket);
socket_getpeername($clients[$i]['socket'], $ip);
$clients[$i]['ip'] = $ip;
printf('Accepting connection into client %d from %s%s', $i, $ip, "'n");
break;
}
// } elseif($i == MAX_CLIENTS - 1) {
// echo 'Too many clients connected!', "'n";
// }
if ($changed_sockets < 1) {
continue;
}
}
}
if ($debug) {
var_dump($clients);
}
for ($i = 0; $i < count($clients); $i++) {
$client = $clients[$i];
// Has our client socket seen any changes?
if (in_array($client['socket'], $read)) {
printf('Client %d has changed! Reading...%s', $i, "'n");
$data = socket_read($client['socket'], 1024);
if ($data === false) {
$error = socket_strerror(socket_last_error());
printf('An error occured...%s%s', $error, "'n");
}
printf("Read raw data %s from client %i%s", $data, $i, "'n");
if ($data === null) {
// disconnected
unset($clients[$i]);
}
$data = trim($data);
if ($data == 'Q') {
printf('Received exit command from client%s', "'n");
socket_close($clients[$i]['socket']);
$status = false;
} elseif ($data) {
// Strip whitespace
printf('Received data: %s from client %d%s', $data, $i, "'n");
$output = sprintf('%s%s%s', $data, "'n", chr(0));
socket_write($client['socket'], $output);
}
}
}
// reset debug
$debug = false;
}
socket_close($socket);
如果你想跳过我所写的内容,这里有一个完整工作的PHP套接字服务器和Android套接字客户端的下载(包含所有源代码):https://developersfound.com/PHP_SocketServer_Android_SocketClient.zip
或者您可能会发现有用的信息,请阅读。。。。
这里的一个重要经验法则是理解"HTTP请求/响应模型"和TCP模型之间的差异。TCP over HTTP的优势在于,您可以对消息进行排队,并利用全双工(双向同时通信),此外,开放式TCP连接的响应能力更强。除非您的解决方案绝对需要排队和/或从全双工中受益,否则您实际上应该使用RPC over HTTP或REST。HTTP在移动设备上更容易实现,也更可靠。在移动设备上长距离移动往往会断开TCP连接,当连接断开时,您将失去任何排队,必须重新连接。重新连接还会占用更多的电池电量,并可能挂断客户端系统。另一个缺点是,一个实时系统最终可能会有很多实时连接,并大大降低服务器的速度;比繁忙的HTTP服务器更是如此。
但是,如果您的解决方案需要或受益于TCP的优势,请继续阅读。。。。
这个代码库(在上面的链接中)有一个功能齐全(自包含)的PHP服务器和一个功能完备的Android套接字客户端。这个代码库应该为在Android中实现客户端套接字提供强有力的参考。该代码库是根据Android最佳实践实现的,也是实现长期运行过程以提高稳定性的有力参考。
值得注意的是,Android文档建议使用Services来实现套接字,因为套接字无法解析。因此,单例类型的模型是必要的。您会注意到,这个代码库使用AIDL与服务通信,并通过广播来更新UI。这是最好的做法,因为必须保护套接字不受垃圾收集和活动重新创建的影响,这通常会破坏套接字连接。通过AIDL和线程执行器绑定的服务都与长期运行进程稳定性的最佳实践相关联。
希望这能有所帮助。
在build.gradle.中添加此库
compile "org.java-websocket:Java-WebSocket:1.3.0"
要连接:
private void connectWebSocket() {
URI uri;
try {
uri = new URI("ws://websockethost:8080");
} catch (URISyntaxException e) {
e.printStackTrace();
return;
}
mWebSocketClient = new WebSocketClient(uri) {
@Override
public void onOpen(ServerHandshake serverHandshake) {
Log.i("Websocket", "Opened");
mWebSocketClient.send("Hello from " + Build.MANUFACTURER + " " + Build.MODEL);
}
@Override
public void onMessage(String s) {
final String message = s;
runOnUiThread(new Runnable() {
@Override
public void run() {
TextView textView = (TextView)findViewById(R.id.messages);
textView.setText(textView.getText() + "'n" + message);
}
});
}
@Override
public void onClose(int i, String s, boolean b) {
Log.i("Websocket", "Closed " + s);
}
@Override
public void onError(Exception e) {
Log.i("Websocket", "Error " + e.getMessage());
}
};
mWebSocketClient.connect();
}
发送消息:
public void sendMessage(String message) {
mWebSocketClient.send(message);
}
参考:https://github.com/elabs/mobile-websocket-example