java - SpringXD 中的计数器/分析

Question

我正在尝试通过入门指南熟悉 SpringXD，但我似乎无法让一个简单的计数器正常工作。

我有一个简单的http源设置，我只想计算经过的消息，但无论我做什么，我都会陷入无限循环并导致堆栈溢出

重现步骤：

# Start the installed redis-server in it's own tab
./redis/bin/redis-server

# start the single node in it's own tab
./xd/bin/xd-singlenode 


# open a new tab for executing the following
curl -d "http --port=9020 | file" http://localhost:8080/streams/httptest
curl -d "Hello basic" http://localhost:9020

# try a counterr
curl -d "tap@httptest | counter --name=postCount" http://localhost:8080/streams/httptest
curl -d "Hello count 1" http://localhost:9020 # begin infinite loop...
curl -d "Hello count 2" http://localhost:9020 # never make it here

我错过了一些明显的东西吗？谢谢！

Answer 1

创建一个水龙头实际上会创建第二个流，因此您需要发布到不同的 URL（您当前正在发布到相同http://localhost:8080/streams/httptest的，我猜这是无限循环的原因）

在尝试创建已使用名称的流时，未来版本将有更好的报告。我创建了https://jira.springsource.org/browse/XD-299来跟踪它

另外，请注意，在单节点模式下运行时，您不需要 redis 服务器。