| #!/Python27/python.exe | |
| print("Content-type: text/html") | |
| print("") | |
| print("<html><head>") | |
| print("") | |
| print("</head><body>") | |
| print("Hello from Python27 .") | |
| print("</body></html>") |
| Function Name | Description |
|---|---|
| array_search() | Searches an array for a given value and returns the key |
| array_splice() | Removes and replaces specified elements of an array |
| <?php | |
| class arrayFunctions{ | |
| public $dialedCustomers; | |
| function __construct($array) { | |
| $this->dialerCustomersCount=$array; | |
| } | |
| public function getValue(){ | |
| var_dump($this->dialerCustomersCount); | |
| } | |
| public function insertData($value) | |
| { | |
| $this->dialerCustomersCount[]=$value; | |
| } | |
| public function checkValue($searchValue) | |
| { | |
| return array_search($searchValue, $this->dialerCustomersCount); | |
| } | |
| public function deleteValue($deleteIndex){ | |
| array_splice($this->dialerCustomersCount, $deleteIndex, 1); | |
| } | |
| } | |
| $input = array("red", "green", "blue", "yellow"); | |
| $values= new arrayFunctions($input); | |
| $values->insertData("57@1000"); | |
| $values->getValue(); | |
| //checking the value | |
| $status=$values->checkValue("green"); | |
| $values->getValue(); | |
| if($status != false){ | |
| $values->deleteValue($status); | |
| $values->getValue(); | |
| } | |
 |
| asterisk |
| { | |
| "require": { | |
| "marcelog/pami": "dev-master", | |
| "educoder/pest": "1.0.0", | |
| "react/zmq": "0.2.*|0.3.*" | |
| } | |
| } |
| require_once 'vendor/autoload.php'; | |
| require_once 'configlocal.php'; | |
| use PAMI\Client\Impl\ClientImpl; | |
| use PAMI\Listener\IEventListener; | |
| use PAMI\Message\Event\EventMessage; | |
| use PAMI\Message\Action\OriginateAction; | |
| use PAMI\Message\Action\StatusAction; | |
| class PamiEventListener implements IEventListener | |
| { | |
| public function __construct($cli) | |
| { | |
| $this->cli = $cli; | |
| } | |
| /** | |
| * To Handle the All Pami Events | |
| * @param EventMessage $event | |
| */ | |
| public function handle(EventMessage $event) | |
| { | |
| echo $strevt = $event->getKeys()['event']; | |
| $this->var_error_log($event->getKeys()); | |
| if ($strevt == 'DialBegin') { | |
| echo "DialBegin event --- \n"; | |
| } | |
| if ($strevt == 'DialEnd') { | |
| echo "Dial end event --- \n"; | |
| } | |
| if ($strevt == 'Hangup') { | |
| echo "Hangup event --- \n"; | |
| } | |
| } | |
| public function var_error_log($object = null) | |
| { | |
| $datetime = date("Y-m-d h:i:s a"); | |
| $contents = PHP_EOL . $datetime . " :"; | |
| ob_start(); // start buffer capture | |
| var_dump($object); // dump the values | |
| $contents .= ob_get_contents(); // put the buffer into a variable | |
| ob_end_clean(); // end capture | |
| //create the log file if not exist | |
| $log_file_path = "log.txt"; | |
| if (file_exists($log_file_path) == false) { | |
| fopen($log_file_path, "w"); | |
| } | |
| error_log($contents, 3, $log_file_path); | |
| } | |
| } | |
| //////////////////////////////////////////////////////////////////////////////// | |
| // Code STARTS. | |
| //////////////////////////////////////////////////////////////////////////////// | |
| error_reporting(E_ALL); | |
| ini_set('display_errors', 1); | |
| try { | |
| $options = array( | |
| 'host' => 122.111.111.222, | |
| 'scheme' => 'tcp://', | |
| 'port' => 5038, | |
| 'username' => 'testuser', | |
| 'secret' => '#######', | |
| 'connect_timeout' => 10, | |
| 'read_timeout' => 10000000 | |
| ); | |
| $phonenumber=1000; | |
| $sipNumber=20000; | |
| $a = new ClientImpl($options); | |
| $eventListener = new PamiEventListener($a); | |
| $a->registerEventListener($eventListener); | |
| $a->open(); | |
| $time = time(); | |
| while (true) { | |
| //(time() - $time) < 60) // Wait for events. | |
| usleep(1000); // 1ms delay | |
| //check the Avilable Agents status | |
| $actionid = md5(uniqid()); | |
| $response = $a->send(new StatusAction()); | |
| $originateMsg = new OriginateAction('SIP/' . $phonenumber . "@voipgw"); | |
| $originateMsg->setContext('dialer'); | |
| $originateMsg->setPriority('1'); | |
| $originateMsg->setExtension($sipNumber); | |
| $originateMsg->setCallerId($sipNumber); | |
| $originateMsg->setAsync(false); | |
| $originateMsg->setActionID($actionid); | |
| $orgresp = $a->send($originateMsg); | |
| $orgStatus = $orgresp->getKeys()['response']; | |
| // Since we declare(ticks=1) at the top, the following line is not necessary | |
| $a->process(); | |
| } | |
| $a->close(); // send logoff and close the connection. | |
| } catch (Exception $e) { | |
| echo $e->getMessage() . "\n"; | |
| } |
Redis created by Salvatore Sanfilippo is an open source, in-memory data structure server with advanced key-value cache and store, often referred to as a NoSQL database. It is also referred to as a data structure server, since it can store strings, hashes, lists, sets, sorted sets, and more.
The essence of a key-value store is the ability to store some data, called a value inside a key. This data can later be retrieved only if we know the exact key used to store it.
Now, let us check how to set up Redis PHP driver.
You need to download the phpredis from github repository https://github.com/nicolasff/phpredis. Once you’ve downloaded it, extract the files to phpredis directory.
| <?php | |
| //echo phpinfo();exit; | |
| //Connecting to Redis server on localhost | |
| $redis = new Redis(); | |
| $status=$redis->connect('XXX.XXXX.XXX.XXX', $portnumber); | |
| echo "<pre>"; | |
| echo "Connection to server sucessfully"; | |
| //check whether server is running or not | |
| echo "Server is running: ".$redis->ping(); | |
| //creating the key | |
| $key="Key_Name"; | |
| $redis->set($key, 'MAK Key Venki'); | |
| //Retreving the specified key value | |
| echo $redis->get($key); | |
| // Get the stored keys and print it | |
| $arList = $redis->keys("*"); | |
| echo "Stored keys in redis:: " ; | |
| print_r($arList); | |
| ?> |
All Our client web pages will be listening to port 8080 for incoming WebSocket connections...but how will it also get updates from another PHP script or another server process event. Enter ZeroMQ. We could use raw sockets, like the ones Ratchet is built on, but ZeroMQ is a library that just makes sockets easier. install zmq
Ratchet is a WebSocket library built on top of a socket library called React. React handles connections and the raw I/O for Ratchet. In addition to React, which comes with Ratchet, we need another library that is part of the React suite: React/ZMQ. This library will bind ZeroMQ sockets to the Reactor core enabling us to handle both WebSockets and ZeroMQ sockets. To install, your composer.json file should look like this:
| { | |
| "autoload": { | |
| "psr-0": { | |
| "MyApp": "src" | |
| } | |
| }, | |
| "require": { | |
| "cboden/ratchet": "0.3.*", | |
| "react/zmq": "0.2.*|0.3.*" | |
| } | |
| } |
| <?php | |
| require dirname(__DIR__) . '/vendor/autoload.php'; | |
| $loop = React\EventLoop\Factory::create(); | |
| $pusher = new MyApp\Pusher; | |
| // Listen for the web server to make a ZeroMQ push after an ajax request | |
| $context = new React\ZMQ\Context($loop); | |
| $pull = $context->getSocket(ZMQ::SOCKET_PULL); | |
| $pull->bind('tcp://127.0.0.1:55556'); // Binding to 127.0.0.1 means the only client that can connect is itself | |
| $pull->on('message', array($pusher, 'onBlogEntry')); | |
| // Set up our WebSocket server for clients wanting real-time updates | |
| $webSock = new React\Socket\Server($loop); | |
| $webSock->listen(8080, '0.0.0.0'); // Binding to 0.0.0.0 means remotes can connect | |
| $webServer = new Ratchet\Server\IoServer( | |
| new Ratchet\Http\HttpServer( | |
| new Ratchet\WebSocket\WsServer( | |
| new Ratchet\Wamp\WampServer( | |
| $pusher | |
| ) | |
| ) | |
| ), | |
| $webSock | |
| ); | |
| $loop->run(); |
| <?php | |
| namespace MyApp; | |
| use Ratchet\MessageComponentInterface; | |
| use Ratchet\ConnectionInterface; | |
| class Chat implements MessageComponentInterface { | |
| protected $clients; | |
| public function __construct() { | |
| $this->clients = new \SplObjectStorage; | |
| } | |
| public function onOpen(ConnectionInterface $conn) { | |
| // Store the new connection to send messages to later | |
| $this->clients->attach($conn); | |
| echo "New connection! ({$conn->resourceId})\n"; | |
| } | |
| public function onMessage(ConnectionInterface $from, $msg) { | |
| $numRecv = count($this->clients) - 1; | |
| echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n" | |
| , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's'); | |
| foreach ($this->clients as $client) { | |
| if ($from !== $client) { | |
| // The sender is not the receiver, send to each client connected | |
| $client->send($msg); | |
| } | |
| } | |
| } | |
| public function onClose(ConnectionInterface $conn) { | |
| // The connection is closed, remove it, as we can no longer send it messages | |
| $this->clients->detach($conn); | |
| echo "Connection {$conn->resourceId} has disconnected\n"; | |
| } | |
| public function onError(ConnectionInterface $conn, \Exception $e) { | |
| echo "An error has occurred: {$e->getMessage()}\n"; | |
| $conn->close(); | |
| } | |
| } |
| <html> | |
| <head> | |
| <title>Testing</title> | |
| <script src="autobahn.js"></script> | |
| <script> | |
| var conn = new ab.Session('ws://localhost:8080',function() { | |
| conn.subscribe('kittensCategory', function(topic, data) { | |
| // This is where you would add the new article to the DOM (beyond the scope of this tutorial) | |
| console.log('New article published to category "' + topic + '" : ' + data.title); | |
| }); | |
| }, | |
| function() { | |
| console.warn('WebSocket connection closed'); | |
| }, | |
| {'skipSubprotocolCheck': true} | |
| ); | |
| </script> | |
| </head> | |
| <body> | |
| <h1> Sample Client web page </h1> | |
| </body> | |
| </html> |
| <?php | |
| // post.php ??? | |
| // This all was here before ;) | |
| $entryData = array( | |
| 'category' =>"kittensCategory" | |
| , 'title' => "Ces Dialer" | |
| , 'article' => "First Articale" | |
| , 'when' => time() | |
| ); | |
| // This is our new stuff | |
| $context = new ZMQContext(); | |
| $socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'my pusher'); | |
| $socket->connect("tcp://localhost:55556"); | |
| $socket->send(json_encode($entryData)); |
| <?php | |
| namespace MyApp; | |
| use Ratchet\ConnectionInterface; | |
| use Ratchet\Wamp\WampServerInterface; | |
| class Pusher implements WampServerInterface { | |
| /** | |
| * A lookup of all the topics clients have subscribed to | |
| */ | |
| protected $subscribedTopics = array(); | |
| public function onSubscribe(ConnectionInterface $conn, $topic) { | |
| echo "subscribe\n"; | |
| print_r($topic->getId()); | |
| $this->subscribedTopics[$topic->getId()] = $topic; | |
| } | |
| public function onUnSubscribe(ConnectionInterface $conn, $topic) { | |
| } | |
| public function onOpen(ConnectionInterface $conn) { | |
| } | |
| public function onClose(ConnectionInterface $conn) { | |
| } | |
| public function onCall(ConnectionInterface $conn, $id, $topic, array $params) { | |
| // In this application if clients send data it's because the user hacked around in console | |
| $conn->callError($id, $topic, 'You are not allowed to make calls')->close(); | |
| } | |
| public function onPublish(ConnectionInterface $conn, $topic, $event, array $exclude, array $eligible) { | |
| // In this application if clients send data it's because the user hacked around in console | |
| $conn->close(); | |
| } | |
| public function onError(ConnectionInterface $conn, \Exception $e) { | |
| } | |
| /** | |
| * @param string JSON'ified string we'll receive from ZeroMQ | |
| */ | |
| public function onBlogEntry($entry) { | |
| $entryData = json_decode($entry, true); | |
| print_r($entryData); | |
| // If the lookup topic object isn't set there is no one to publish to | |
| if (!array_key_exists($entryData['category'], $this->subscribedTopics)) { | |
| return; | |
| } | |
| $topic = $this->subscribedTopics[$entryData['category']]; | |
| // re-send the data to all the clients subscribed to that category | |
| $topic->broadcast($entryData); | |
| } | |
| } |
