草庐IT

c++ - boost ASIO 和线程之间的消息传递

coder 2024-02-22 原文

我正在设计一个 websocket 服务器，它接收一条消息并将其保存到一个嵌入式数据库。为了阅读消息，我正在使用 boost asio .要将消息保存到嵌入式数据库，我会看到几个选项:

  1. 在同一线程上收到消息后，立即同步保存消息。
  2. 在单独的线程上异步保存消息。

我很确定第二个答案是我想要的。但是，我不确定如何将消息从套接字线程传递到 IO 线程。我看到以下选项:

  1. 每个线程使用一个 io 服务并使用 post function线程之间进行通信。这里不得不担心锁的争用。我应该吗？
  2. 使用 Linux 域套接字在线程之间传递消息。据我了解，没有锁争用。在这里，我可能可以使用 BOOST_ASIO_DISABLE_THREADS 宏来获得一些性能 boost 。

此外，我相信拥有多个 IO 线程会有所帮助，这些线程会以循环方式接收消息以保存到嵌入式数据库。

哪种架构的性能最高？除了我提到的架构之外，还有其他替代方案吗？

一些注意事项:

  • 消息的长度正好是 8 个字节。
  • 不能使用外部数据库。数据库必须嵌入到运行中 过程。
  • 我正在考虑使用 RocksDB作为嵌入式 数据库。

最佳答案

我认为您不想使用 unix 套接字，它总是需要系统调用并通过内核传递数据。这通常比线程间机制更适合作为进程间机制。

除非您的数据库 API 要求所有调用都从同一个线程进行(我对此表示怀疑)，否则您不必为此使用单独的 boost::asio::io_service。相反，我会创建一个 io_service::strand在您现有的 io_service 实例上并使用 strand::dispatch()任何阻塞数据库任务的成员函数(而不是 io_service::post())。以这种方式使用 strand 可以保证最多一个线程可能会被阻止访问数据库，而 io_service 实例中的所有其他线程可用于服务非数据库任务。

为什么这比使用单独的 io_service 实例更好？一个优点是具有一组线程的单个实例在编码和维护方面稍微简单一些。另一个小优点是，如果可以的话，使用 strand::dispatch() 将在当前线程中执行(即，如果没有任务已经在 strand 中运行)，这可能避免上下文切换。

对于最终优化，我同意使用其入队操作无法进行系统调用的专用队列可能是最快的。但是考虑到您有生产者的网络输入/输出和消费者的磁盘输入/输出，我不认为队列的实现会成为您的瓶颈。

关于c++ - boost ASIO 和线程之间的消息传递，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37419685/

amp传递codeio_serviceboostc++multithreadingsockets

有关c++ - boost ASIO 和线程之间的消息传递的更多相关文章

  1. ruby-on-rails - Rails 应用程序之间的通信 - 2

    我构建了两个需要相互通信和发送文件的Rails应用程序。例如，一个Rails应用程序会发送请求以查看其他应用程序数据库中的表。然后另一个应用程序将呈现该表的json并将其发回。我还希望一个应用程序将存储在其公共(public)目录中的文本文件发送到另一个应用程序的公共(public)目录。我从来没有做过这样的事情，所以我什至不知道从哪里开始。任何帮助，将不胜感激。谢谢! 最佳答案 无论Rails是什么，几乎所有Web应用程序都有您的要求，大多数现代Web应用程序都需要相互通信。但是有一个小小的理解需要你坚持下去，网站不应直接访问彼此

  2. ruby-on-rails - 如何优雅地重启 thin + nginx？ - 2

    我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server

  3. ruby - RuntimeError(自动加载常量 Apps 多线程时检测到循环依赖 - 2

    我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样？我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用，需要1秒才能返回，我有100,000多个页面要访问，所以我试图运行多个线程来解决这个问题。有更好的方法吗？classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("

  4. ruby-on-rails - 如何在 Rails View 上显示错误消息？ - 2

    我是rails的新手，想在form字段上应用验证。myviewsnew.html.erb.....模拟.rbclassSimulation{:in=>1..25,:message=>'Therowmustbebetween1and25'}end模拟Controller.rbclassSimulationsController我想检查模型类中row字段的整数范围，如果不在范围内则返回错误信息。我可以检查上面代码的范围，但无法返回错误消息提前致谢 最佳答案 关键是您使用的是模型表单，一种显示ActiveRecord模型实例属性的表单。c

  5. ruby - ＃之间？ Cooper 的 *Beginning Ruby* 中的错误或异常 - 2

    在Cooper的书BeginningRuby中，第166页有一个我无法重现的示例。classSongincludeComparableattr_accessor:lengthdef(other)@lengthother.lengthenddefinitialize(song_name,length)@song_name=song_name@length=lengthendenda=Song.new('Rockaroundtheclock',143)b=Song.new('BohemianRhapsody',544)c=Song.new('MinuteWaltz',60)a.betwee

  6. ruby-on-rails - `a ||= b` 和 `a = b if a.nil 之间的区别？ - 2

    我正在检查一个Rails项目。在ERubyHTML模板页面上，我看到了这样几行:我不明白为什么不这样写:在这种情况下，||=和ifnil?有什么区别？ 最佳答案 在这种特殊情况下没有区别，但可能是出于习惯。每当我看到nil?被使用时，它几乎总是使用不当。在Ruby中，很少有东西在逻辑上是假的，只有文字false和nil是。这意味着像if(!x.nil?)这样的代码几乎总是更好地表示为if(x)除非期望x可能是文字false。我会将其切换为||=false，因为它具有相同的结果，但这在很大程度上取决于偏好。唯一的缺点是赋值会在每次运行

  7. ruby - rails 3 redirect_to 将参数传递给命名路由 - 2

    我没有找到太多关于如何执行此操作的信息，尽管有很多关于如何使用像这样的redirect_to将参数传递给重定向的建议:action=>'something',:controller=>'something'在我的应用程序中，我在路由文件中有以下内容match'profile'=>'User#show'我的表演Action是这样的defshow@user=User.find(params[:user])@title=@user.first_nameend重定向发生在同一个用户Controller中，就像这样defregister@title="Registration"@user=Use

  8. ruby-on-rails - 如何生成传递一些自定义参数的 `link_to` URL？ - 2

    我正在使用RubyonRails3.0.9，我想生成一个传递一些自定义参数的link_toURL。也就是说，有一个articles_path(www.my_web_site_name.com/articles)我想生成如下内容:link_to'Samplelinktitle',...#HereIshouldimplementthecode#=>'http://www.my_web_site_name.com/articles?param1=value1¶m2=value2&...我如何编写link_to语句“alàRubyonRailsWay”以实现该目的？如果我想通过传递一些

  9. ruby - 使用 Ruby 通过 Outlook 发送消息的最简单方法是什么？ - 2

    我的工作要求我为某些测试自动生成电子邮件。我一直在四处寻找，但未能找到可以快速实现的合理解决方案。它需要在outlook而不是其他邮件服务器中，因为我们有一些奇怪的身份验证规则，我们需要保存草稿而不是仅仅发送邮件的选项。显然win32ole可以做到这一点，但我找不到任何相当简单的例子。 最佳答案 假设存储了Outlook凭据并且您设置为自动登录到Outlook，WIN32OLE可以很好地完成此操作:require'win32ole'outlook=WIN32OLE.new('Outlook.Application')message=

  10. Ruby - 如何将消息长度表示为 2 个二进制字节 - 2

    我正在使用Ruby，我正在与一个网络端点通信，该端点在发送消息本身之前需要格式化“header”。header中的第一个字段必须是消息长度，它被定义为网络字节顺序中的2二进制字节消息长度。比如我的消息长度是1024。如何将1024表示为二进制双字节？ 最佳答案 Ruby(以及Perl和Python等)中字节整理的标准工具是pack和unpack。ruby的packisinArray.您的长度应该是两个字节长，并且按网络字节顺序排列，这听起来像是n格式说明符的工作:n|Integer|16-bitunsigned,network(bi

随机推荐