Great, you should ensure that the vert.x mqtt server has enough secondary development capabilities if you want to reuse it. After all, we need the server react with RocketMQ cluster.
Regards On Tue, Mar 20, 2018 at 2:45 AM, Sudaraka Yasindu <sudarakayasi...@gmail.com > wrote: > Hi Yukon and Von, > I found Vert.x MQTT server[1] provides a nice way of implementing MQTT > broker functionality. I just played around and created a simple mqtt broker > with it. The repo is on github[2] and I have uploaded a short screencast > to the google drive[3]. I used MQTTLens[4] as the MQTT client here. Thank > you > > [1] http://vertx.io/docs/vertx-mqtt-server/java/ > [2] https://github.com/sudaraka94/mqtt-broker-test > [3] https://drive.google.com/open?id=1W4QOCRsONYr4Tl7RSDolqQHnNgRwJQUY > [4] https://chrome.google.com/webstore/detail/mqttlens/hemoj > aaeigabkbcookmlgmdigohjobjm > > Regards, > Sudaraka Jayathilaka > *Undergraduate* > Department of Computer Science and Engineering > University of Moratuwa > > > On Tue, Mar 20, 2018 at 12:08 AM, Sudaraka Yasindu < > sudarakayasi...@gmail.com> wrote: > >> Hi Yukon and Von, >> I found Vert.x MQTT server[1] provides a nice way of implementing MQTT >> broker functionality. I just played around and created a simple mqtt broker >> with it. The repo is on github[2] and I have attached a short screen cast >> with this email. I used MQTTLens[3] as the MQTT client here. Thank you >> >> [1] http://vertx.io/docs/vertx-mqtt-server/java/ >> [2] https://github.com/sudaraka94/mqtt-broker-test >> [3] https://chrome.google.com/webstore/detail/mqttlens/hemoj >> aaeigabkbcookmlgmdigohjobjm >> >> Regards, >> Sudaraka Jayathilaka >> *Undergraduate* >> Department of Computer Science and Engineering >> University of Moratuwa >> >> >> On Sat, Mar 17, 2018 at 2:27 PM, yukon <yu...@apache.org> wrote: >> >>> Cool, looking forward to your design and reuse code is ok if the license >>> is compatible with ASF license. More details please refer to >>> https://www.apache.org/legal/resolved.html >>> <https://www.apache.org/legal/resolved.html#category-b> >>> >>> Sudaraka Yasindu <sudarakayasi...@gmail.com>于2018年3月17日 周六下午3:53写道： >>> >>>> Hi Yukon and Von Gosling, >>>> I read the research paper you mentioned in the thread and got a brief >>>> idea about the proxy server and its functionalities >>>> >>>> >>>> I figured the proxy server implementation must have mainly two >>>> components. One component for handling all the functionalities regarding >>>> the MQTT protocol and the other component which is responsible for >>>> translating messages between RocketMQ message format and MQTT message >>>> format. >>>> >>>> *MQTT Broker* >>>> >>>> I found a lot of existing opensource MQTT Broker implementations. I >>>> found Eclipse Mosquitto easy to work with. In the project I will be able to >>>> use one of these brokers as references and implement the component myself. >>>> Will I be able to reuse some of the code from those broker implementations >>>> ? (If the code licensing permits). >>>> >>>> *Protocol Conversion Component* >>>> >>>> Message format used in MQTT protocol and RocketMQ are slightly >>>> different. This component will convert messages in MQTT format to RocketMQ >>>> component and in the other way too. >>>> >>>> This is my current idea regarding the project and I'm reading more >>>> about Linkerd. Is there anything to be corrected? >>>> >>>> Regards, >>>> Sudaraka Jayathilaka >>>> *Undergraduate* >>>> Department of Computer Science and Engineering >>>> University of Moratuwa >>>> >>>> >>>> On Sat, Mar 17, 2018 at 8:43 AM, Sudaraka Yasindu < >>>> sudarakayasi...@gmail.com> wrote: >>>> >>>>> Hi Yukon, >>>>> I already found the research paper and I'm studying it. Thank you a >>>>> lot for the direction. I will soon come up with a brief design for the >>>>> project. >>>>> >>>>> Regards, >>>>> Sudaraka Jayathilaka >>>>> *Undergraduate* >>>>> Department of Computer Science and Engineering >>>>> University of Moratuwa >>>>> >>>>> >>>>> On Sat, Mar 17, 2018 at 8:33 AM, yukon <yu...@apache.org> wrote: >>>>> >>>>>> As we are implementing a proxy server, so may Linkerd[1] could give >>>>>> us some >>>>>> hints. >>>>>> >>>>>> [1]. https://linkerd.io/ >>>>>> >>>>>> Regards, >>>>>> yukon >>>>>> >>>>>> On Fri, Mar 16, 2018 at 9:38 PM, Sudaraka Yasindu < >>>>>> sudarakayasi...@gmail.com >>>>>> > wrote: >>>>>> >>>>>> > Thank you for the clarification Yukon. I am looking into it. >>>>>> > >>>>>> > Regards, >>>>>> > Sudaraka Jayathilaka >>>>>> > *Undergraduate* >>>>>> > Department of Computer Science and Engineering >>>>>> > University of Moratuwa >>>>>> > >>>>>> > >>>>>> > On Fri, Mar 16, 2018 at 6:42 PM, yukon <yu...@apache.org> wrote: >>>>>> > >>>>>> > > Hi, >>>>>> > > >>>>>> > > A paper implemented a MQTT push server based on RocketMQ, maybe >>>>>> it helps. >>>>>> > > >>>>>> > > And we don't want to depend on the third-party server, just >>>>>> develop a >>>>>> > > proxy server that supports MQTT protocol and talk to our rocketmq >>>>>> > cluster. >>>>>> > > >>>>>> > > Regards, >>>>>> > > yukon >>>>>> > > >>>>>> > > 1. Yue, Ma, et al. "A MQTT Protocol Message Push Server Based on >>>>>> > > RocketMQ." Intelligent Computation Technology and Automation >>>>>> (ICICTA), >>>>>> > 2017 >>>>>> > > 10th International Conference on. IEEE, 2017. >>>>>> > > >>>>>> > > >>>>>> > > >>>>>> > > On Fri, Mar 16, 2018 at 8:18 PM, Sudaraka Yasindu < >>>>>> > > sudarakayasi...@gmail.com> wrote: >>>>>> > > >>>>>> > >> Hi Yukon & Vongosling, >>>>>> > >> I started experimenting with Eclipse Mosquitto as it has been >>>>>> used in >>>>>> > >> many projects. Will it be suitable to be used in the project as >>>>>> Yukon >>>>>> > >> mentioned in Jira or should I choose another MQTT broker? . I >>>>>> created >>>>>> > this >>>>>> > >> with my current understanding about the project. >>>>>> > >> >>>>>> > >> >>>>>> > >> Is the main target of the proxy server implementation is to add >>>>>> the >>>>>> > >> protocol conversion functionality?. Can you please give me your >>>>>> inputs >>>>>> > on >>>>>> > >> the above diagram. Thank you >>>>>> > >> >>>>>> > >> Regards, >>>>>> > >> Sudaraka Jayathilaka >>>>>> > >> *Undergraduate* >>>>>> > >> Department of Computer Science and Engineering >>>>>> > >> University of Moratuwa >>>>>> > >> >>>>>> > >> >>>>>> > >> On Sat, Mar 10, 2018 at 12:12 AM, Sudaraka Yasindu < >>>>>> > >> sudarakayasi...@gmail.com> wrote: >>>>>> > >> >>>>>> > >>> I'm really sorry if my diagram is not visible in the previous >>>>>> email. I >>>>>> > >>> will attach it here in case it isn't visible >>>>>> > >>> >>>>>> > >>> >>>>>> > >>> Regards, >>>>>> > >>> Sudaraka Jayathilaka >>>>>> > >>> *Undergraduate* >>>>>> > >>> Department of Computer Science and Engineering >>>>>> > >>> University of Moratuwa >>>>>> > >>> m: +94715271890 <+94%2071%20527%201890> >>>>>> > >>> e: sudarakayasi...@gmail.com >>>>>> > >>> <https://web.facebook.com/sudara.yasi> >>>>>> > >>> <https://twitter.com/Sudaraka94> >>>>>> > >>> <https://www.linkedin.com/in/sudarakajayathilaka> >>>>>> > >>> <https://www.instagram.com/sudaraka94/> >>>>>> > >>> >>>>>> > >>> >>>>>> > >>> On Fri, Mar 9, 2018 at 11:57 PM, Sudaraka Yasindu < >>>>>> > >>> sudarakayasi...@gmail.com> wrote: >>>>>> > >>> >>>>>> > >>>> Hi Yukon, >>>>>> > >>>> I will continue my discussion here from now on (Which I >>>>>> continued on >>>>>> > >>>> JIRA). As per my understanding, MQTT protocol follows a >>>>>> publisher >>>>>> > >>>> subscriber publish subscribe architecture. I read the RocketMQ >>>>>> > >>>> documentation and it occurred to me that, message broadcasting >>>>>> using >>>>>> > >>>> RocketMQ can be used here. I ran these examples and I got a >>>>>> brief >>>>>> > knowledge >>>>>> > >>>> on working with message broadcasting with RocketMQ. >>>>>> > >>>> I thought of a setup where each IoT Sensor(device which >>>>>> produces >>>>>> > >>>> messages) sends messages with a unique topic. So the >>>>>> subscribers can >>>>>> > >>>> subscribe to the message stream using the same unique topic. I >>>>>> > sketched my >>>>>> > >>>> current idea like this. >>>>>> > >>>> >>>>>> > >>>> But still I'm not sure this requires separate proxy for >>>>>> publishers and >>>>>> > >>>> a separate proxy for subscribers. Can you please input your >>>>>> > suggestions. >>>>>> > >>>> Thank you. >>>>>> > >>>> >>>>>> > >>>> Regards, >>>>>> > >>>> Sudaraka Jayathilaka >>>>>> > >>>> *Undergraduate* >>>>>> > >>>> Department of Computer Science and Engineering >>>>>> > >>>> University of Moratuwa >>>>>> > >>>> m: +94715271890 <+94%2071%20527%201890> >>>>>> > >>>> e: sudarakayasi...@gmail.com >>>>>> > >>>> <https://web.facebook.com/sudara.yasi> >>>>>> > >>>> <https://twitter.com/Sudaraka94> >>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka> >>>>>> > >>>> <https://www.instagram.com/sudaraka94/> >>>>>> > >>>> >>>>>> > >>>> >>>>>> > >>> >>>>>> > >> >>>>>> > > >>>>>> > >>>>>> >>>>> >>>>> >>>> >> >
