公式にはまだないようですが、なんとなくdownloadして使ってみてるんですが、、、、、
とりあえず、、
fsockopen は必ずエラーになることがわかりました。
しょうがないので、こんな感じで、ベタな関数を使ってクラスをかきました。
ローレベルの関数は問題なく実行できたので、とりあえずはこれは使ってみます。。。。
そういえば、、readfile関数も微妙に怪しい。。。。。^^;^^;
class alexsock{
private $portn;
private $address;
private $sock;
private $counter;
//-------------------------
/* 初期値 */
//-------------------------
function __construct(){
$this->address = 'localhost';
$this->portn = 20002;
$this->counter = 10;
}
//-------------------------
function __destruct(){
// とりあえず特にやることなし。
}
//-------------------------
function setAddress($v){
$this->address = $v;
}
//-------------------------
function setPort($v){
$this->portn = $v;
}
//-------------------------
function create(){
$this->sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($this->sock === false) return false;
return true;
}
//-------------------------
function connect(){
$result = socket_connect($this->sock, $this->address, $this->portn);
if($result === false) return false;
return true;
}
//-------------------------
function setNonblock(){
socket_set_nonblock($this->sock);
}
//-------------------------
function setBlock(){
socket_set_block($this->sock);
}
//-------------------------
function setWaitTime($milisec){
$this->counter = $milisec / 100;
if($this->counter < 1) $this->counter = 1;
}
//-------------------------
function close(){
socket_close ($this->sock);
}
//-------------------------
function write($msg){
$writelen = socket_write($this->sock, $msg, mb_strlen($msg));
return $writelen;
}
//-------------------------
function read($slen){
$readlen = socket_read($this->sock, $slen);
return $readlen;
}
//-------------------------
function readEx($slen){
for($w=0;$w<$this->counter;$w++){
if($readstr == false){
$readstr = socket_read($this->sock,$slen);
if($readstr != false) return $readstr;
usleep(100000); // マイクロ秒単位
}
}
return false;
}
//-------------------------
// ありがちな準備
//-------------------------
function alexPrepare($add="127.0.0.1",$portn=20002,$milisec=10000){
$this->setAddress($add);
$this->setPort($portn);
$this->setWaitTime($milisec);
$b = $this->create();
if(!$b) return false;
$b = $this->connect();
if(!$b) return false;
$this->setNonblock();
return true;
}
//-------------------------
}
