在PinnedDispatcher上运行的执行元中使用ZMQ套接字是否安全？

Question

据我从文档中所知，ZeroMQ套接字不应该从不同的线程中使用（例如，从不同的线程中读取/写入）。

这反过来又阻止了我在默认调度程序上运行的Akka执行元中使用ZMQ套接字（无法保证哪个线程将执行我的receive方法）。

使用PinnedDispatcher是否允许我在Actor中安全地使用这样的套接字，前提是我注意不要阻塞（至少不要阻塞太长的时间）？

通过:https://doc.akka.io/docs/akka/2.5/dispatchers.html#types-of-dispatchers

我使用的是JeroMQ 0.4.0和Akka 2.5。我意识到Akka曾经有一个ZeroMQ扩展，但似乎大部分都被放弃了。

Answer 1

ZeroMQ，从最早的版本_{（您指的是API版本2.1，而在2018/Q2+发布并可用的API4.2+版本）}开始，就在一个共享的值集下构建。Zen-of-Zero，它努力使事情尽可能高效地发生，以一种资源友好的方式发生，并且只获得一个合理数量的延迟（最好没有）。

然而，这并不意味着可以不计成本地实现这一目标，对吗？

如果以适当的方式使用适当的工具，没有人会受到伤害，对吗？

干净的“无共享”ZeroMQ设计要比尝试处理越来越多的设计工件更安全、更快速（如果您的领域需要质量保证过程，那么在验收预定之前就交付设计验证和验证证明就越好--试着想象一下测试、质量保证/验证证明的成本，只是希望具有确定性、非阻塞性、无错误和健壮/弹性的现场操作。）

注意:
ZeroMQsocket()-实例不是TCP-Socket-as-you-know-it。最好在不到五秒钟的时间内阅读ZeroMQ层次结构的主要概念差异，或者在这里阅读其他帖子和讨论。

context()实例在其自己的控制域下具有自己的I/O线程池，并且在相应的context的socket()实例允许的与相应的context的（组）I/O线程的关联之间具有类似“DMA”的映射器，因此关于“钉扎”的全局视图可能不会影响预期的资源映射首选项。

#####################################
# Akka ZeroMQ Reference Config File #
#####################################

# This is the reference config file that contains all the default settings.
# Make your edits/overrides in your application.conf.

akka {

  zeromq {

    # The default timeout for a poll on the actual zeromq socket.
    poll-timeout = 100ms

    # Timeout for creating a new socket
    new-socket-timeout = 5s

    socket-dispatcher {
      # A zeromq socket needs to be pinned to the thread that created it.
      # Changing this value results in weird errors and race conditions within
      # zeromq
      executor = thread-pool-executor
      type = "PinnedDispatcher"
      thread-pool-executor.allow-core-timeout = off
    }
  }
}