PHP进程通信之共享内存+UNIX Socket（二十四节）

<?php
// sem key
$sem_key = ftok( __FILE__, 'b' );
$sem_id = sem_get( $sem_key );
// shm key
$shm_key = ftok( __FILE__, 'm' );
$shm_id = shm_attach( $shm_key, 1024, 0666 );
const SHM_VAR = 1;
$child_pid = [];
// fork 2 child process
// 下面逻辑很简单，就是两个子进程去操作同一块共享内存
// 每个进程在试图读或者写共享内存前，都必须先获得锁
// 当然，操作完毕后，一定记得要释放锁
for( $i = 1; $i <= 2; $i++ ){
    $pid = pcntl_fork();
    if( $pid < 0 ){
        exit();
    } else if( 0 == $pid ) {
        // 子进程中，在操作shm共享内存前，首先获取sem锁
        sem_acquire( $sem_id );
        if( shm_has_var( $shm_id, SHM_VAR ) ){
            $counter = shm_get_var( $shm_id, SHM_VAR );
            $counter += 1;
            shm_put_var( $shm_id, SHM_VAR, $counter );
        } else {
            $counter = 1;
            shm_put_var( $shm_id, SHM_VAR, $counter );
        }
        // 释放锁，一定要记得释放，不然就一直会被阻锁死
        sem_release( $sem_id );
        exit;
    } else if( $pid > 0 ) {
        $child_pid[] = $pid;
    }
}
while( !empty( $child_pid ) ){
    foreach( $child_pid as $pid_key => $pid_item ){
        pcntl_waitpid( $pid_item, $status, WNOHANG );
        unset( $child_pid[ $pid_key ] );
    }
}
// 休眠2秒钟，2个子进程都执行完毕了
sleep( 2 );
echo '最终结果'.shm_get_var( $shm_id, SHM_VAR ).PHP_EOL;
// 记得删除共享内存数据，删除共享内存是有顺序的，先remove后detach，顺序反过来php可能会报错
shm_remove( $shm_id );
shm_detach( $shm_id );

/***********  一侧代码  **********/
<?php
// 这里要注意的是，第一个参数用AF_UNIX表示要创建一个本地unix域
// 但是最后一个参数。。。给老子折腾的不清，只有用0才不会报错
// 但是，他TM文档里压根没提这档子事！fk
$listen_socket = socket_create( AF_UNIX, SOCK_STREAM, 0 );
// 这会儿就不需要把socket bind到IP+PORT上了
// 而是bind到一个sock文件上
$file = "./server.sock";
socket_bind( $listen_socket, $file );
socket_listen( $listen_socket );
while ( true ) {
    $connection_socket = socket_accept( $listen_socket );
    $ret = socket_recv( $connection_socket, $recv_content, 2048, 0 );
    echo $recv_content;
    $encode_ret = "higood";
    socket_write( $connection_socket, $encode_ret, strlen( $encode_ret ) );
}

/***********  另一侧代码  **********/
<?php
$conn_socket = socket_create( AF_UNIX, SOCK_STREAM, 0 );
$file = "./server.sock";
socket_connect( $conn_socket, $file );
socket_write( $conn_socket, "HI,I am coming." );
socket_recv( $conn_socket, $recv_content, 2048, 0 );
echo $recv_content;