20

我在 php 中有客户端和服务器通过共享内存进行通信，现在我想使用 Boost.Interprocess 访问这个碎片内存对象，我该如何访问它？服务器.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";
}

客户端.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 library Docs 中找到了解决方案：

来自 boost Docs 的基于 XSI_KEY 的示例

4

1 回答 1

1

我不是你在做什么的专家，但根据我在你的问题和我的知识中读到的内容，我会放弃那个纯粹的 IPC 东西并将它包装到ZMQ 中（你会发现你需要的每种语言的包装器）。它旨在解决这类问题并提供可以在 IPC 或更常见的 TCP 套接字上运行的单一 API。

于 2013-06-23T09:59:34.760 回答