如何在PHP和Boost库IPC之间进行通信?

20

我有一个使用共享内存进行通信的PHP客户端和服务器,现在我想使用Boost.Interprocess访问这个共享内存对象,我该如何访问它? server.php:

  function create_image($str){
  // Create a blank image and add some text
  $im = imagecreatetruecolor(300, 20);
  $text_color = imagecolorallocate($im, 233, 14, 91);
  $stringBanner=exec("date").$str;
  imagestring($im, 1, 5, 5,  $stringBanner , $text_color);

  ob_start();
   imagejpeg($im);
  $i = ob_get_contents();
  ob_get_clean(); 
  imagedestroy($im);
   return $i; 
  }  
  echo "\n".__FILE__."\n";
  $shm_key = ftok(__FILE__, 't');
  echo $shm_key."\n";


  $shm_id = shmop_open($shm_key, "a", 0, 0); 
 if ($shm_id) {
  //it is already created
  shmop_delete($shm_id);
  shmop_close($shm_id); 
 } 
 //you need to create it with shmop_open using "c" only
 echo "try to create\n";
 if(!$shm_id = shmop_open($shm_key, "c", 0777, 1024*4))exit(-1);


 echo "ID ".$shm_id."\n";
 $i=0;
 for(;;){
 sleep(1);
 $s="i=".$i++;
 $str=$i;
 $im=serialize(create_image($str));

 $data=serialize(strlen($im));
 $shm_bytes_written = shmop_write($shm_id, $data, 0);
 $shm_bytes_written = shmop_write($shm_id, $im, 32);
 echo $shm_bytes_written." bytes  is written: ".$s." ID = $shm_id\n";
}

client.php

<?php
$shm_key =1946222626;// ftok(__FILE__, 't');
$shm_id = shmop_open(
         $shm_key, "a", 
         0644,1024*4
         );


 $s=shmop_size($shm_id);
 $data = unserialize(
        shmop_read( $shm_id, 0, 
            31)
       );

 $im =  unserialize(
       shmop_read( $shm_id, 32, 
               $data)
       );
  // Set the content type header - in this case image/jpeg
 header('Content-Type: image/jpeg');
// Output the image
echo $im;

我应该向Boost提供什么样的密钥才能获取这个内存区域?

boost_client.cpp

#include <boost/interprocess/shared_memory_object.hpp> 
#include <iostream> 
#include "sys/msg.h"

int main() 
{ 
    int msqid;
    key_t key;
    char f[]="??????";
    int mid;

    //key = ftok(, 't');
    //msqid = msgget(key, 0666 | IPC_CREAT);

    std::cout<<msqid<<std::endl;
    boost::interprocess::shared_memory_object 
    shdmem(boost::interprocess::open_or_create, 
           f,//"shmem_server", 
           boost::interprocess::read_write); 
    shdmem.truncate(1024); 
    std::cout << shdmem.get_name() << std::endl; 
    boost::interprocess::offset_t size; 
    if (shdmem.get_size(size)) 
    std::cout << size << std::endl; 
} 

编辑:

我在Boost IPC库文档中找到了解决方案:

来自Boost文档的基于XSI_KEY的示例


PHP扩展使用System V IPC keys,那么Boost使用哪一个? - hakre
当然可以,但它有点隐藏在幕后。 - Arman
6
请发布一个包含您找到的解决方案的答案。 - oxygen
@Arman 如果你想在 PHP 和其他语言之间共享数据,请尝试使用 Thrift,这是由 Facebook 开发的。 - kirugan
谢谢,我看了一下它。很不错,但是我的项目是用boost开发的,所以我会继续使用boost :) - Arman
显示剩余6条评论
1个回答

1

我不是你所做的领域的专家,但从你的问题和我的知识来看,我建议你放弃使用纯IPC,而是将其包装在ZMQ中(你可以找到你需要的每种语言的包装器)。它旨在解决这些问题并提供一个单一的API,可以在IPC或更常见的TCP套接字上运行。


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接