小编blo*_*her的帖子

我希望能够远程连接到暴露了JMX的Java服务,但是它被防火墙阻止了.我曾尝试使用ssh本地端口转发,但连接失败.看看wireshark,看来当你尝试连接jconsole时,它想要在连接到被防火墙阻止的端口9999之后通过一些短暂的端口连接.

有没有办法让jconsole只通过9999连接或使用代理？是这篇文章仍然是最好的解决办法？或者,我错过了什么？

我正在尝试使用Avro来读取/写入Kafka的消息.有没有人有一个使用Avro二进制编码器编码/解码将被放在消息队列中的数据的例子？

我需要Avro部件而不是Kafka部件.或者,也许我应该看一个不同的解决方案？基本上,我正试图在空间方面找到更有效的JSON解决方案.刚刚提到Avro,因为它比JSON更紧凑.

如何为风暴拓扑提供自定义配置？例如,如果我有一个我构建的拓扑连接到MySQL集群,并且我希望能够更改我需要连接的服务器而无需重新编译,我该怎么做？我的偏好是使用配置文件,但我担心的是文件本身没有部署到集群,因此它不会被运行(除非我对集群如何工作的理解是有缺陷的).到目前为止,我在运行时将配置选项传递到风暴拓扑中的唯一方法是通过命令行参数,但是当您获得大量参数时,这很麻烦.

一个想法确实是利用shell脚本将文件读入变量并将该变量的内容作为字符串传递给拓扑,但是如果可能的话我想要一些更清洁的东西.

有人遇到过这种情况么？如果是这样,你是如何解决的？

编辑:

似乎需要提供更多说明.我的方案是我有一个拓扑,我希望能够在不同的环境中部署,而无需重新编译它.通常情况下,我会创建一个配置文件,其中包含数据库连接参数之类的内容并将其传入.我想知道如何在Storm中执行类似的操作.

我正在尝试创建一个这样的新模型:

rails generate model Tags name:string

当我运行它时,我收到以下错误:

base.rb:266:in `const_defined?': wrong constant name tags (NameError)

有什么想法吗？我尝试将标签更改为ReportTags,它仍然给了我同样的错误.

我们正在研究使用Docker以及Mesos/Marathon或Kubernetes来托管集群.但是,我们还没有真正看到任何答案的一个问题是如何允许群集服务正确连接到彼此.我所看到的所有那些在加入集群之前需要知道至少一个其他节点.有些人需要了解每个节点.但是,在Kubernetes和Mesos中,没有办法提前知道这些IP地址是什么.

那么,有什么最佳实践吗？如果它有所帮助,我们正在寻求部署为容器的一些技术是ElasticSearch,ActiveMQ和MongoDB.可能还有其他人.

虽然我认为答案是否定的,但我觉得我仍然应该问:是否可以从Docker容器中监控主机系统？为了使部署和升级更容易,我希望我可以在容器中放置一些监视工具.具体来说,我正在考虑像atop,sar等工具.

思考？

谢谢.

我们有一个 Web 服务器和一个客户端，两者都是用 Go 编写的，可以相互交互。我们希望 HAProxy 在服务器的多个实例之间负载平衡请求，但它不起作用。当服务器仍在运行时，客户端将始终连接到同一服务器。

如果我查看“netstat -anp”的输出，我可以看到客户端和服务器之间通过 HAProxy 建立了持久连接。我尝试将响应中的连接标头设置为“关闭”，但这根本不起作用。

不用说，我对此完全感到困惑。我的第一个问题是，这是客户端、服务器还是 HAProxy 的问题吗？如何强制客户端断开连接？我是否遗漏了一些与此相关的内容？Curl 工作正常，所以我知道 HAProxy 可以进行负载平衡，但curl 在完成后也会完全关闭，因此我怀疑是持久连接导致了我的问题，因为客户端和服务器长时间运行。

仅供参考，我在服务器上使用 go-martini。

谢谢。

我做了一些挖掘,但没有找到任何令人满意的东西,所以我问:他们是否有任何最佳实践或使用return和runtime.Goexit退出goroutine的优点/缺点？到目前为止,我在一些测试中遇到的唯一问题是,如果你使用的是waitgroups,它可能不会调用Done函数.

特定于等待组(如果感兴趣):在我的代码库中的一些快速测试中,我创建了一个匿名函数,作为goroutine执行,以测试应该在goroutine中运行的方法.我试图使用defer让它调用wg.Done()当函数调用runtime.Goexit时,但它没有用.不确定这是故意还是错误.

代码示例:

go func() {
    wg.Add(1)
    defer wg.Done()
    // Function goes here...
}()