Socket Programming in PhP

class Socket extends controller
{

function Socket()
{
parent::Controller();
$this->load->model(‘socket_model’);
}

function index()
{
$this->socket_model->socket();

}
function socket_load()
{

// don’t timeout
set_time_limit (0);

// set some variables
$host = “127.0.0.1”;
$port = 1234;

// create socket
$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die(“Could not create socket\n”);
// bind socket to port
$result = socket_bind($socket, $host, $port) or die(“Could not bind to socket\n”);

// start listening for connections
$result = socket_listen($socket, 3) or die(“Could not set up socket listener\n”);

echo “Waiting for connections…\n”;

// accept incoming connections
// spawn another socket to handle communication
$spawn = socket_accept($socket) or die(“Could not accept incoming connection\n”);

echo “Received connection request\n”;

// write a welcome message to the client
$welcome = “Roll up, roll up, to the greatest show on earth!\n? “;
socket_write($spawn, $welcome, strlen ($welcome)) or die(“Could not send connect string\n”);

// keep looping and looking for client input
do
{
// read client input
$input = socket_read($spawn, 1024, 1) or die(“Could not read input\n”);

if (trim($input) != “”)
{
echo “Received input: $input\n”;

// if client requests session end
if (trim($input) == “END”)
{
// close the child socket
// break out of loop
socket_close($spawn);
break;
}
// otherwise…
else
{
// reverse client input and send back
$output = strrev($input) . “\n”;
socket_write($spawn, $output . “? “, strlen (($output)+2)) or die(“Could not write output\n”);
echo “Sent output: ” . trim($output) . “\n”;
}
}

} while (true);

// close primary socket
socket_close($socket);
echo “Socket terminated\n”;
}
}
?>


class Socket_model extends Model
{
/**
* Constructor
*
*/
function Socket_model()
{
parent::Model();

}

function socket()
{

$data[‘action’] = $this->config->item(‘base_url’).“socket/socket_load”;
$this->load->view(‘socket_view’, $data);
}
}
?>




input form simple will b here.
and client from requerst will be just passing through here



// where is the socket server?
$host=“127.0.0.1”;
$port = 1234;

// create socket
$socket = socket_create(‘AF_INET’, ‘SOCK_STREAM’, 0) or die(“Could not create socket\n”);

// connect to server
$result = socket_connect($socket, $host, $port) or die(“Could not connect to server\n”);

socket_read ($socket, 1024) or die(“Could not read server response\n”);

// send string to server
socket_write($socket, $message, strlen($message)) or die(“Could not send data to server\n”);

// get server response
$result = socket_read ($socket, 1024) or die(“Could not read server response\n”);

// end session
socket_write($socket, “END”, 3) or die(“Could not end session\n”);

// close socket
socket_close($socket);

// clean up result
$result = trim($result);
$result = substr($result, 0, strlen($result)-1);

// print result to browser
?>
Server said:
}
?>