Thank you a lot Yukon,I replied for the comment there. I have been working on the component which connect the proxy server with RocketMQ. As I understand the whole implementation will be having two servers. One server as the MQTT broker and the other server listening and waiting for the messages from RocketMQ brokers. Can you please add your inputs on this? I have attached a simple diagram depicting my idea. Thank you
Regards, Sudaraka Jayathilaka *Undergraduate* Department of Computer Science and Engineering University of Moratuwa On Fri, Mar 23, 2018 at 4:58 PM, yukon <yu...@apache.org> wrote: > Looks great, I added some comments~ > > On Thu, Mar 22, 2018 at 5:19 PM, Sudaraka Yasindu < > sudarakayasi...@gmail.com > > wrote: > > > Hi Yukon and Von, > > I started drafting my proposal. Can you please take a look and let me > know > > whether I should change the content or add something more. I already > shared > > the proposal through GSoC dashboard. Thank you > > > > Proposal : > > https://docs.google.com/document/d/1A3XY3KPz- > > yUTubWK2ij1oXJneOis45a1kB6Qwefbh9U/edit?usp=sharing > > > > Regards, > > Sudaraka Jayathilaka > > *Undergraduate* > > Department of Computer Science and Engineering > > University of Moratuwa > > > > > > On Tue, Mar 20, 2018 at 8:39 AM, yukon <yu...@apache.org> wrote: > > > > > 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=1W4QOCRsONYr4Tl7RSDolqQHnNgRwJ > QUY > > > > [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/> > > > >>>>>> > >>>> > > > >>>>>> > >>>> > > > >>>>>> > >>> > > > >>>>>> > >> > > > >>>>>> > > > > > >>>>>> > > > > >>>>>> > > > >>>>> > > > >>>>> > > > >>>> > > > >> > > > > > > > > > >
