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/ hemojaaeigabkbcookmlgmdigohjobjm 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/ > hemojaaeigabkbcookmlgmdigohjobjm > > 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/> >>>>> > >>>> >>>>> > >>>> >>>>> > >>> >>>>> > >> >>>>> > > >>>>> > >>>>> >>>> >>>> >>> >
