2 files changed, 41 insertions, 0 deletions
diff --git a/php_kvrocks/kvrocks.php b/php_kvrocks/kvrocks.php
new file mode 100644
index 0000000..d40a773
--- /dev/null
+++ b/php_kvrocks/kvrocks.php
@@ -0,0 +1,31 @@
+<?php
+if ( !extension_loaded('sockets') )
+    die( 'the damn sockets extension is not loaded' );
+$sck = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
+if ( $sck === false )
+  die( 'Failed to create socket' );
+if ( !socket_connect($sck, '127.0.0.1', 6000) ){
+  socket_close( $sck );
+  die( 'Failed to connect to kvrocks' );
+}
+if ( socket_send($sck, "GET stderr64_data\r\n", strlen("GET stderr64_data\r\n"), 0) == false ){
+  socket_close( $sck );
+  die(' Failed to send retrieval command' );
+}
+$recv_data = 'tmp';
+$avb = socket_recv( $sck, $recv_data, 2048, MSG_PEEK );
+echo strval($avb).' bytes:<br>';
+if ( socket_recv($sck, $recv_data, $avb, MSG_WAITALL) === false ){
+  socket_close( $sck );
+  die( 'Failed to recv data' );
+}
+socket_shutdown( $sck );
+socket_close( $sck );
+$ddata = json_decode( explode("\r\n", $recv_data)[1], true );
+var_dump( $ddata );
+echo '<br>Cookies: '.strval($ddata['cookies']).'<br>group: '.$ddata['group'].'<br>';
+unset( $ddata );
+unset( $recv_dec );
+unset( $recv_data );
+exit( 0 );
+?>
diff --git a/php_kvrocks/kvrocks2.php b/php_kvrocks/kvrocks2.php
new file mode 100644
index 0000000..0d821cd
--- /dev/null
+++ b/php_kvrocks/kvrocks2.php
@@ -0,0 +1,10 @@
+<?php
+$sck = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
+socket_connect( $sck, '127.0.0.1', 6000 );
+socket_write( $sck, 'GET stderr64_data\r\n', strlen('GET stderr64_data\r\n') );
+$rd = socket_read( $sck, 255 );
+socket_shutdown( $sck );
+socket_close( $sck );
+var_dump( json_decode($rd, true) );
+exit( 0 );
+?>