php[world] 2015 Call for Speakers

socket_write

(PHP 4 >= 4.1.0, PHP 5)

socket_writeEscreve em um socket

Descrição

int socket_write ( resource $socket , string $buffer [, int $length ] )
Aviso

Esta função é EXPERIMENTAL. O comportamento desta função, seu nome, incluindo toda documentação pode ser modificado sem aviso em futuras versões do PHP. Esta função deve ser usada por sua própria conta e risco.

A função socket_write() escreve em um socket socket de buffer.

O parâmetro opcional length pode especificar um comprimento alternativo de bytes escritos para o socket. Se esse comprimento é maior do que o comprimento do buffer, isso será silenciosamente truncado para o comprimento do buffer.

Retorna o número de bytes escritos com sucesso para o socket ou FALSE em um erro. O código de erro pode ser retornado com socket_last_error(). Esse código deve ser passado para socket_strerror() para pegar uma explicação textual do erro.

Nota:

socket_write() não necessariamente escreve todos os bytes dados do buffer. Isso é valido, dependendo da rede, buffers etc., somente uma quantidade segura de dados, sempre um byte, é escrito embora seu buffer seja maior. Você deve prestar atenção para involuntariamente esquecer de transmitir o restante dos seus dados.

Nota:

Isso é perfeitamente válido para socket_write() retornar zero que significa que não tem bytes para escrever. Tenha certeza de usar o operador === para checar por FALSE em caso de um erro.

Veja também socket_accept(), socket_bind(), socket_connect(), socket_listen(), socket_read() e socket_strerror().

add a note add a note

User Contributed Notes 7 notes

up
3
revelable at hotmail dot com
4 years ago
Here we have the same function to write a socket but with improved performance.

If the messager are not larger, they will be written entirely with a single socket_write() call. And is not needed to call the substr() function for the first bucle.

<?php
$st
="Message to sent";
$length = strlen($st);
       
    while (
true) {
       
       
$sent = socket_write($socket, $st, $length);
           
        if (
$sent === false) {
       
            break;
        }
           
       
// Check if the entire message has been sented
       
if ($sent < $length) {
               
           
// If not sent the entire message.
            // Get the part of the message that has not yet been sented as message
           
$st = substr($st, $sent);
               
           
// Get the length of the not sented part
           
$length -= $sent;

        } else {
           
            break;
        }
           
    }
?>
up
2
gtk at linux dot online dot no
12 years ago
from http://www.manualy.sk/sock-faq/unix-socket-faq-2.html
read() is equivalent to recv() with a flags parameter of 0. Other values for the flags parameter change the behaviour of recv(). Similarly, write() is equivalent to send() with flags == 0.
up
1
webmaster at you-are-infected dot com
8 years ago
If you connect to a Server in a way like you do with telnet or some similar protokoll you may have problems with sending data to the server. I found out that at some servers there is a different between:

<?php
   
    socket_write
($my_socket, $line, strlen ($line));
   
socket_write ($my_socket, "\r\n", strlen ("\r\n"));
   
?>
witch worked at least, and
<?php
    socket_write
($my_socket, $line."\r\n", strlen ($line."\r\n"));
?>
wich made the server stop sending any data.

I hope this helps to save a lot of time. I needed about two days to find out, that this was the problem ;)
up
1
php at deguest dot asia
27 days ago
I often read in php docs users not checking for the php function returned value, and in the case of socket_write, I could not see here in the comment anyone botering to read on the socket the server reply.
Then one user thought it would be a good idea to use usleep after a socket_write on a smtp connection.
Actually, if you check the server reply, not only will it give time for the server to reply before you write again on the socket, but also this is a great opportunity to check what the server replied you.
For instance, for smtp connection :
In this example MAIL_SERVER, MAIL_PORT and DEBUG are constants I defined.
<?php
function sendmail( $param )
{
   
$from    = &$param[ 'from' ];
   
$to      = &$param[ 'to' ];
   
$message = &$param[ 'data' ];
   
   
$isError = function( $string )
    {
        if(
preg_match( '/^((\d)(\d{2}))/', $string, $matches ) )
        {
            if(
$matches[ 2 ] == 4 || $matches[ 2 ] == 5 ) return( $matches[ 1 ] );
        }
        else
        {
            return(
false );
        }
    };
   
    try
    {
       
$socket = null;
        if( (
$socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP ) ) == false )
        {
            throw new
Exception( sprintf( "Unable to create a socket: %s", socket_strerror( socket_last_error() ) ) );
        }
        if( !
socket_connect( $socket, MAIL_SERVER, MAIL_PORT ) )
        {
            throw new
Exception( sprintf( "Unable to connect to server %s: %s", MAIL_SERVER, socket_strerror( socket_last_error() ) ) );
        }
       
$read = socket_read( $socket, 1024 );
        if(
$read == false )
        {
            throw new
Exception( sprintf( "Unable to read from socket: %s", socket_strerror( socket_last_error() ) ) );
        }
       
        if(
socket_write( $socket, sprintf( "HELO %s\r\n", gethostname() ) ) === false )
        {
            throw new
Exception( sprintf( "Unable to write to socket: %s", socket_strerror( socket_last_error() ) ) );
        }
       
$read = socket_read( $socket, 1024 );
        if(
$read == false )
        {
            throw new
Exception( sprintf( "Unable to read from socket: %s", socket_strerror( socket_last_error() ) ) );
        }
        else
        {
            if( (
$errCode = $isError( $read ) ) ) throw new Exception( "Server responded with an error code $errCode" );
        }
       
        if(
socket_write( $socket, sprintf( "MAIL FROM: %s\r\n", $from ) ) === false )
        {
            throw new
Exception( sprintf( "Unable to write to socket: %s", socket_strerror( socket_last_error() ) ) );
        }
       
$read = socket_read( $socket, 1024 );
        if(
$read == false )
        {
            throw new
Exception( sprintf( "Unable to read from socket: %s", socket_strerror( socket_last_error() ) ) );
        }
        else
        {
            if( (
$errCode = $isError( $read ) ) ) throw new Exception( "Server responded with an error code $errCode" );
        }
       
/* And some more code, but not enough place in comment */
       
return( $totalWriten );
    }
    catch(
Exception $e )
    {
       
$ERROR = sprintf( "Error sending mail message at line %d. ", $e->getLine() ) . $e->getMessage();
        return(
false );
    }
}
up
0
divinity76 at gmail dot com
3 months ago
function AddTCPChecksum(&$data){
//feel free to add some error handling for strlen($data)>65535...
$data=pack("v",strlen($data)).$data;
}
up
-1
masterwaster at gmail dot com
6 years ago
Hi,
if you got same problems like i have

<?php
@socket_write($xd, "Good Bye!\n\r");
@
socket_shutdown($xd, 2);
@
socket_close($xd);
?>

wont'tx send "Good Bye!\n\r" to the opened socket.

but if you put a
usleep or something like echo "";
between write and shutdown its working.
up
-4
jean at briskula dot si
4 years ago
Some clients (Flash's XMLSocket for example) won't fire a read event until a new line is recieved.

<?php
   
/*
     * Write to a socket
     * add a newline and null character at the end
     * some clients don't read until new line is recieved
     *
     * try to send the rest of the data if it gets truncated
     */
   
function write(&$sock,$msg) {
       
$msg = "$msg\n\0";
       
$length = strlen($msg);
        while(
true) {
           
$sent = socket_write($sock,$msg,$length);
            if(
$sent === false) {
                return
false;
            }
            if(
$sent < $length) {
               
$msg = substr($msg, $sent);
               
$length -= $sent;
                print(
"Message truncated: Resending: $msg");
            } else {
                return
true;
            }
        }
        return
false;
    }
?>
To Top