broker

    0热度

    1回答

    我 celery==3.1.23 Django==1.9.1 redis==2.10.5 ii redis-server 2:2.8.19-3 amd64 Persistent key-value database with networ ii redis-tools 2:2.8.19-3 amd64 Persistent key-value database with n

    1热度

    1回答

    我是MQTT协议新手。在我阅读文档时,我看不到任何删除已发布主题的功能。我的目的是让发布者删除已发布的主题。我错过了mqtt文档中的某些内容吗?任何建议?谢谢 !

    0热度

    2回答

    我对我的项目中使用MQTT有个疑问。我只想知道是否有可能我使用RaspberryPi作为MQTT代理(服务器)从MQTT中发布的设备接收数据,然后同时这个RaspberryPi将MQTT中的相同数据发布给另一个订户?如果可能的话,那么第二部分的消息中介将会是什么?我的意思是,我希望RaspberryPi成为设备控制器(用于处理设备数据),同时将数据发布到另一个MQTT订户。这可能吗? 谢谢你这么多

    1热度

    1回答

    我是卡夫卡的新手。试图实现消费者和生产者类来发送和接收消息。需要为两个类别配置bootstrap.servers,这是经纪人的IP和端口列表,由,分隔。例如, producerConfig.put("bootstrap.servers", "172.16.20.207:9946,172.16.20.234:9125,172.16.20.36:9636"); 由于应用程序将集群的

    0热度

    2回答

    mqtt客户端具有相同的客户端ID 如何关闭旧连接? 就是这样。 New connection from 192.168.3.57 on port 1883. 1479826181: Client paho166768969170988 already connected, closing old connection. 1479826181: Client paho1667689691709

    0热度

    1回答

    我有一个标准的ActiveMQ代理 private static String localVMurl = "vm://localhost"; broker = new BrokerService(); broker.addConnector(localVMurl); broker.start(); ,一切都很好。我的目标是,消费者通过特定主题与经纪人建立联系。一

    2热度

    1回答

    我正尝试使用proxybroker为某些国家/地区生成具有活动代理的文件。我总是遇到同样的错误,试图获取代理。该错误似乎是proxbroker使用的packe中的编码/解码错误。但我怀疑可能有更好的方式来使用代理经纪人。 这是引起问题的代码: def gather_proxies(countries): """ This method uses the proxybroker package

    1热度

    1回答

    我对Arduino相当陌生,对于我希望使用UNO向MQTT代理推送/发布通知的项目,请让代理将通知推送到订阅Android应用程序我正在发展。 我有一个ESP8266为我的Arduino传入。我已经做了相当多的研究,但在拼凑事物时遇到了一些麻烦。我已经阅读过Arduino作为订阅者,或者作为服务器,或者Android作为发布者的文章,但没有一篇针对这个具体实现。我认为迄今为止我所知道的是: 1:由

    2热度

    1回答

    我是Fiware用户,我在云上的不同VM上部署了orion context broker GE,cepheus GE和iotagent-ul实例。我已经在注册过程中在注册过程中在上下文代理中创建了在注册请求中指定命令属性的IOT代理中注册了一个设备,并且它的对应实体已经创建。 现在,当我注册一个带有其属性和命令属性 及其名称和类型的设备时,该设备在iot代理上注册,其实体也在上下文代理中创建。但奇

    0热度

    1回答

    当我尝试测试我非常简单的消息流我得到这个错误: MQJE001: Completion Code '2', Reason '2495'. 我见过的其他问题与此相关的问题,但没有解决办法帮我解决这个... 这句话: Caused by: java.lang.UnsatisfiedLinkError: mqjbnd (Not found in java.library.path) 表明,有libmqj