1

我有两个程序的一个非常小的示例，一个用于写入共享内存段，另一个用于从中读取。我意识到（和其他容器）存在潜在问题，std::string因此尝试boost::interprocess::string了哪个是boost::containers::string. 我很确定这缺少一些非常基本和简单的东西，但看不到它！

无论如何，概要是当字符串很小（我认为虽然比 SSO 大）时，运行第一个程序会写入内存，而第二个程序读取得非常好。但是，如果我像这里的示例那样使字符串非常大，则读取程序会出现段错误。如果读取和写入都在同一个进程中，但功能不同（因此除了通过 ipc 之外不共享任何数据。代码如下 writeipc.cc

#include <boost/interprocess/managed_shared_memory.hpp> 
#include <boost/interprocess/containers/string.hpp>
#include <iostream> 
#include <utility> 

int main() 
{
  typedef boost::interprocess::string bi_string;

  boost::interprocess::shared_memory_object::remove("Test"); 
  boost::interprocess::managed_shared_memory managed_shm(boost::interprocess::create_only, "Test", 65536); 


  bi_string* i = managed_shm.construct<bi_string>("string")("abcdefghijklmnopqrstuvwxyzaskl;dfjaskldfjasldfjasdl;fkjwrotijuergonmdlkfsvmljjjjjjjjjjjjjj");  // make smaller (ie "jjjjjjjjjjjjjj" and test passes 
  std::cout << "inserting into shm" << *i << std::endl; 

  std::pair<bi_string*, size_t> q = managed_shm.find<bi_string>("string"); 
  std::cout << *q.first << std::endl;
 while(true)
    std::cout << "still running"; // hack to keep process running (not required)
}

readipc.cc

#include <boost/interprocess/managed_shared_memory.hpp> 
#include <boost/interprocess/containers/string.hpp>
#include <iostream> 

int main() 
{
  typedef boost::interprocess::string bi_string;
  boost::interprocess::managed_shared_memory managed_shm(boost::interprocess::open_only, "Test"); 

  std::pair<bi_string*, std::size_t> p = managed_shm.find<bi_string>("string"); 
  std::cout << "existing value" << *p.first << std::endl; 

}
4

1 回答 1

4

好的，答案与分配器有关。

我发布了我认为可以让其他人快速了解如何开始使用 IPC 的答案。我发现了很多关于网络的例子，这些例子并没有很好地解释这个过程，并且给人的印象是使用普通字符串等就可以了，直到你从不同的过程中阅读。因此，要完全实施解决方案，需要一些额外的小步骤。

本质上，您不能使用普通 stl 类型容器提供的分配器。这记录在这里

这是在哪里分配的？

Boost.Interprocess 容器被放置在共享内存/内存映射文件等...同时使用两种机制：

Boost.Interprocess construct<>, find_or_construct<>... functions. These functions place a C++ object in the shared memory/memory mapped

文件。但这仅放置对象，而不是该对象可能动态分配的内存。共享内存分配器。这些允许分配共享内存/内存映射文件部分，以便容器可以动态分配内存片段来存储新插入的元素。

这意味着要将任何 Boost.Interprocess 容器（包括 Boost.Interprocess 字符串）放在共享内存或内存映射文件中，容器必须：

Define their template allocator parameter to a Boost.Interprocess allocator.
Every container constructor must take the Boost.Interprocess allocator as parameter.
You must use construct<>/find_or_construct<>... functions to place the container in the managed memory.

如果您执行前两点但不使用construct<> 或find_or_construct<>，则您正在创建一个仅放置在您的进程中的容器，但它为共享内存/内存映射文件中的包含类型分配内存。

我创建了几个示例函数，可以在这里找到

上面缺少的是

namespace bi = boost::interprocess;
typedef bi::allocator<char, bi::managed_shared_memory::segment_manager> CharAllocator;
typedef bi::basic_string<char, std::char_traits<char>, CharAllocator> bi_string;

现在这是一个字符串，当我们可以获得分配器时可以存储它。这意味着像这样从你的内存段中获取分配器

  bi::managed_shared_memory segment(bi::create_only, "shm name",
                                                     65536);
  // Create an object of Type initialized to type
  CharAllocator charallocator(segment.get_segment_manager());

现在 charallocator 可用于构造一个字符串类型，该类型将在共享内存位置工作并能够正确读回。字符串创建为：

 bi_string str(charallocator);

然后，您可以为此分配一个 cstring。例如 std::string test("a test string");

str = test.c_str();

如果您构建一个段，您的字符串将被存储

segment.construct<bi_string>("some name")(str)

您可以在共享内存存储中存储许多段。我希望这对其他人有帮助。代码在上面的链接中都可以通过测试获得。

于 2013-10-24T16:19:47.513 回答