最新文章列表

Kafka部署及使用(单节点/集群)

从kafka-0.9版本及以后,kafka的消费者组和offset信息就不存zookeeper了,而是存到broker服务器上 三种安装Kafka的方式,分别为:单节点单Broker部署、单节点多Broker部署、集群部署(多节点多Broker)。实际生产环境中使用的是第三种方式,以集群的方式来部署Kafka。Kafka强依赖ZK,如果想要使用Kafka,就必须安装ZK,Kafka中的消费偏置 ...
flylynne 评论(0) 有1915人浏览 2019-04-14 23:40

activemq Broker启动方式

1、直接运行安装目录的bin\activemq.bat   2、可以通过在应用程序中以编码的方式启动broker,例如:            Java代码   BrokerService broker =new BrokerService();   broker.setBrokerName("testName");
dwj147258 评论(0) 有522人浏览 2017-03-17 13:35

MQTT协议 - 安全问题

一、概述:         物联网的核心是连接万物,通过交换并分析数据使得生活更舒适与便捷。不过,敏感数据泄露或者设备被非法控制可不是闹着玩 ...
Josh_Persistence 评论(0) 有5878人浏览 2016-05-19 20:07

Broker启用安全认证,需要用户名和密码验证

Broker需要在配置文件中开安全认证,客户端或者其他Broker连接时,需要通过对应的用户名和密码来访问,默认没有安全认证。配置样例如下: (1)、指定加密的环境变量: 删除 <!-- Allows us to use system properties as variables in this configuration file --> <bean class=&qu ...
can_do 评论(0) 有801人浏览 2016-03-21 11:30

client与broker断开后重新连接

qpid的client端有可能会由于某种原因与broker断开连接,如网络连接断开,broker的节点删除等等。 公司的项目需要用java编写一个Service,用来监听broker的消息。要求如果与broker断开后,必须尝试重新连接。 那应该完成以下一个步骤: (1)检测到client与服务器断开。 (2)如果断开,尝试重新连接。 对于(1),javax.jms.Connection对象可以 ...
flying.xu77 评论(0) 有2272人浏览 2013-06-11 15:22

MQTT的学习研究(四)moquette-mqtt 的使用之mqtt Blocking API客户端订阅并接收主题信息

   在上面两篇关于mqtt的broker的启动和mqtt的服务端发布主题信息之后,我们客户端需要订阅相关的信息并接收相关的主题信息。 package com.etrip.mqtt; import java.net.URISyntaxException; import org.fusesource.mqtt.client.BlockingConnection; import org. ...
longgangbai 评论(1) 有14622人浏览 2012-10-16 15:51

MQTT的学习研究(二)moquette-mqtt 的使用之mqtt broker的启动

        在MQTT 官网 (http://mqtt.org/software)中有众多MQTT的实现方式。具体参看官网,Moquette是基于Apache Mina 的模型的一个Java MQTT broker。使用过Mina的同学发现其实broker的启动过程就是一个Mina应用的启动。      在MQTT moquette 中采用MINA作为底层消息的传递方式  本类的目的启动M ...
longgangbai 评论(17) 有36831人浏览 2012-10-16 15:42

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics