scala - 如何在 FP 中保持收听？

Question

我想使用 Kafka 在微服务之间发送消息。

Kafka采用发布订阅机制，即生产者生产消息，kafka接收消息并订阅给消费者。消费者总是监听传入消息的事件并做出相应的 react 。

我的问题是，如何使用函数式编程语言(scala、haskell)构建一个系统来监听传入的事件？

它就像一个 http 服务器，正在监听传入的请求。

我认为，由于副作用，它需要一个 IO Monad，这会发生。以及如何让它一直运行？简单的外观？

Answer 1

我不懂 Scala，但在 Haskell 中，答案是，就像在命令式语言中一样，但在 IO monad 中。

可能有像函数式响应式编程这样的系统可以让您以函数式方式编写监听器，但最终它们是用于生成命令式程序的声明式语言，并且在幕后它们将是命令式的。

有些人认为 Haskell 是他们最喜欢的命令式语言!这个想法并不是说 Haskell 没有副作用，而是类型系统明确明确了它们发生的位置和顺序。