Haskell：延迟测试连接可用性N次（从scotty到mongodb）

Question

我对 scotty web 应用程序和 mongodb 服务以正确的顺序启动有一个愚蠢的问题。 我先使用 systemd 启动 mongodb，然后再启动 scotty web 应用程序。由于某种原因它不起作用。应用程序错误，来自 mongodb 驱动程序的 connect: does not exist (Connection refused) 表示连接尚未准备好。

所以我的问题。如何以 0.5 秒的间隔测试连接可用性说 3 次，然后才出现错误？

这是应用程序的主要功能

main :: IO ()
main = do
  pool <- createPool (runIOE $ connect $ host "127.0.0.1") close 1 300 5
  clearSessions pool
  let r = \x -> runReaderT x pool
  scottyT 3000 r r basal

basal :: ScottyD ()
basal = do
  middleware $ staticPolicy (noDots >-> addBase "static")
  notFound $ runSession
  routes

虽然应用服务是在 mongodb 服务之后排序的，但在应用启动期间与 mongodb 的连接仍然不可用。所以我得到了上面提到的错误。 这是 systemd 服务文件，以避免有关正确服务顺序的问题。

[Unit]
Description=Basal Web Application
Requires=mongodb.service
After=mongodb.service iptables.service network-online.target

[Service]
User=http
Group=http
WorkingDirectory=/srv/http/basal/
ExecStart=/srv/http/basal/bin/basal
StandardOutput=journal
StandardError=journal

[Install]
WantedBy=multi-user.target

我不知道为什么在正确的服务顺序下无法连接到 mongodb。 所以我想用 0.5 秒的延迟用 haskell 代码探测连接可用性三次，然后出错。我该怎么做？

谢谢。

Answer 1

我猜从您使用的函数来看，您使用的是 mongoDB 1.5.0 之类的东西。

这里，connect 在 IOE monad 中返回一些东西，它是 ErrorTIOErrorIO 的别名。

所以最好的方法是使用ErrorT 提供的重试机制。由于它是MonadPlus 的一个实例，如果我们不关心检查具体错误，我们可以使用mplus：

retryConnect :: Int -> Int -> Host -> IOE Pipe
retryConnect retries delayInMicroseconds host
    | retries > 0 =
            connect host `mplus`
                (liftIO (threadDelay delayInMicroseconds) >>
                   retryConnect (retries - 1) delayInMicroseconds host)
    | otherwise = connect host

（threadDelay 来自Control.Concurrent）。

然后将connect替换为retryConnect 2 500000，它会在第一次失败后以500,000微秒的间隔（即0.5s）重试两次。

如果您确实想检查特定错误，请改用catchError 并检查错误以决定是吞下它还是重新抛出它。