You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by Sudaraka Yasindu <su...@gmail.com> on 2018/03/09 18:27:09 UTC
[GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
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
e: sudarakayasindu@gmail.com
<https://web.facebook.com/sudara.yasi> <https://twitter.com/Sudaraka94>
<https://www.linkedin.com/in/sudarakajayathilaka>
<https://www.instagram.com/sudaraka94/>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
Hi Yukon and Von,
I have uploaded the final version of my proposal. Please let me know If
there is any problem with the proposal. Looking forward for a great summer
with RocketMQ.
Thank you
Regards,
Sudaraka Jayathilaka
*Undergraduate*
Department of Computer Science and Engineering
University of Moratuwa
On Sat, Mar 24, 2018 at 4:15 PM, Sudaraka Yasindu <sudarakayasindu@gmail.com
> wrote:
> 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 <
>> sudarakayasindu@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 <
>> > > sudarakayasindu@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=1W4QOCRsONYr4Tl7RSDolqQHnNg
>> RwJQUY
>> > > > [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 <
>> > > > sudarakayasindu@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 <su...@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 <
>> > > >>>> sudarakayasindu@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 <
>> > > >>>>>> sudarakayasindu@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 <
>> > > >>>>>> > > sudarakayasindu@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 <
>> > > >>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
>> > > >>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
>> > > >>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
>> > > >>>>>> > >>>> <https://twitter.com/Sudaraka94>
>> > > >>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>> > > >>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
>> > > >>>>>> > >>>>
>> > > >>>>>> > >>>>
>> > > >>>>>> > >>>
>> > > >>>>>> > >>
>> > > >>>>>> > >
>> > > >>>>>> >
>> > > >>>>>>
>> > > >>>>>
>> > > >>>>>
>> > > >>>>
>> > > >>
>> > > >
>> > >
>> >
>>
>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
> sudarakayasindu@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 <
> > > sudarakayasindu@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 <
> > > > sudarakayasindu@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 <su...@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 <
> > > >>>> sudarakayasindu@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 <
> > > >>>>>> sudarakayasindu@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 <
> > > >>>>>> > > sudarakayasindu@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 <
> > > >>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
> > > >>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
> > > >>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
> > > >>>>>> > >>>> <https://twitter.com/Sudaraka94>
> > > >>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
> > > >>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
> > > >>>>>> > >>>>
> > > >>>>>> > >>>>
> > > >>>>>> > >>>
> > > >>>>>> > >>
> > > >>>>>> > >
> > > >>>>>> >
> > > >>>>>>
> > > >>>>>
> > > >>>>>
> > > >>>>
> > > >>
> > > >
> > >
> >
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by yukon <yu...@apache.org>.
Looks great, I added some comments~
On Thu, Mar 22, 2018 at 5:19 PM, Sudaraka Yasindu <sudarakayasindu@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 <
> > sudarakayasindu@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 <
> > > sudarakayasindu@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 <su...@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 <
> > >>>> sudarakayasindu@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 <
> > >>>>>> sudarakayasindu@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 <
> > >>>>>> > > sudarakayasindu@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 <
> > >>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
> > >>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
> > >>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
> > >>>>>> > >>>> <https://twitter.com/Sudaraka94>
> > >>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
> > >>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
> > >>>>>> > >>>>
> > >>>>>> > >>>>
> > >>>>>> > >>>
> > >>>>>> > >>
> > >>>>>> > >
> > >>>>>> >
> > >>>>>>
> > >>>>>
> > >>>>>
> > >>>>
> > >>
> > >
> >
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
> sudarakayasindu@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 <
> > sudarakayasindu@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 <su...@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 <
> >>>> sudarakayasindu@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 <
> >>>>>> sudarakayasindu@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 <
> >>>>>> > > sudarakayasindu@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 <
> >>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
> >>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
> >>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
> >>>>>> > >>>> <https://twitter.com/Sudaraka94>
> >>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
> >>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
> >>>>>> > >>>>
> >>>>>> > >>>>
> >>>>>> > >>>
> >>>>>> > >>
> >>>>>> > >
> >>>>>> >
> >>>>>>
> >>>>>
> >>>>>
> >>>>
> >>
> >
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by yukon <yu...@apache.org>.
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 <sudarakayasindu@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 <
> sudarakayasindu@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 <su...@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 <
>>>> sudarakayasindu@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 <
>>>>>> sudarakayasindu@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 <
>>>>>> > > sudarakayasindu@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 <
>>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
>>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
>>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
>>>>>> > >>>> <https://twitter.com/Sudaraka94>
>>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
>>>>>> > >>>>
>>>>>> > >>>>
>>>>>> > >>>
>>>>>> > >>
>>>>>> > >
>>>>>> >
>>>>>>
>>>>>
>>>>>
>>>>
>>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
sudarakayasindu@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 <su...@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 <
>>> sudarakayasindu@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 <
>>>>> sudarakayasindu@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 <
>>>>> > > sudarakayasindu@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 <
>>>>> > >> sudarakayasindu@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: sudarakayasindu@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 <
>>>>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
>>>>> > >>>> <https://web.facebook.com/sudara.yasi>
>>>>> > >>>> <https://twitter.com/Sudaraka94>
>>>>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>>>>> > >>>> <https://www.instagram.com/sudaraka94/>
>>>>> > >>>>
>>>>> > >>>>
>>>>> > >>>
>>>>> > >>
>>>>> > >
>>>>> >
>>>>>
>>>>
>>>>
>>>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <sudarakayasindu@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 <
>> sudarakayasindu@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 <
>> > > sudarakayasindu@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 <
>> > >> sudarakayasindu@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: sudarakayasindu@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 <
>> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
>> > >>>> <https://web.facebook.com/sudara.yasi>
>> > >>>> <https://twitter.com/Sudaraka94>
>> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>> > >>>> <https://www.instagram.com/sudaraka94/>
>> > >>>>
>> > >>>>
>> > >>>
>> > >>
>> > >
>> >
>>
>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
> sudarakayasindu@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 <
> > > sudarakayasindu@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 <
> > >> sudarakayasindu@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: sudarakayasindu@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 <
> > >>> sudarakayasindu@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: sudarakayasindu@gmail.com
> > >>>> <https://web.facebook.com/sudara.yasi>
> > >>>> <https://twitter.com/Sudaraka94>
> > >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
> > >>>> <https://www.instagram.com/sudaraka94/>
> > >>>>
> > >>>>
> > >>>
> > >>
> > >
> >
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by yukon <yu...@apache.org>.
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 <sudarakayasindu@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 <
> > sudarakayasindu@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 <
> >> sudarakayasindu@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: sudarakayasindu@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 <
> >>> sudarakayasindu@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: sudarakayasindu@gmail.com
> >>>> <https://web.facebook.com/sudara.yasi>
> >>>> <https://twitter.com/Sudaraka94>
> >>>> <https://www.linkedin.com/in/sudarakajayathilaka>
> >>>> <https://www.instagram.com/sudaraka94/>
> >>>>
> >>>>
> >>>
> >>
> >
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
> sudarakayasindu@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 <
>> sudarakayasindu@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: sudarakayasindu@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 <
>>> sudarakayasindu@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: sudarakayasindu@gmail.com
>>>> <https://web.facebook.com/sudara.yasi>
>>>> <https://twitter.com/Sudaraka94>
>>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>>>> <https://www.instagram.com/sudaraka94/>
>>>>
>>>>
>>>
>>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by yukon <yu...@apache.org>.
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 <sudarakayasindu@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 <
> sudarakayasindu@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: sudarakayasindu@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 <
>> sudarakayasindu@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: sudarakayasindu@gmail.com
>>> <https://web.facebook.com/sudara.yasi>
>>> <https://twitter.com/Sudaraka94>
>>> <https://www.linkedin.com/in/sudarakajayathilaka>
>>> <https://www.instagram.com/sudaraka94/>
>>>
>>>
>>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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 <
sudarakayasindu@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: sudarakayasindu@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 <
> sudarakayasindu@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: sudarakayasindu@gmail.com
>> <https://web.facebook.com/sudara.yasi> <https://twitter.com/Sudaraka94>
>> <https://www.linkedin.com/in/sudarakajayathilaka>
>> <https://www.instagram.com/sudaraka94/>
>>
>>
>
Re: [GSOC][ROCKETMQ-127]Providing a rocketmq-proxy to support MQTT protocol
Posted by Sudaraka Yasindu <su...@gmail.com>.
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
e: sudarakayasindu@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 <sudarakayasindu@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: sudarakayasindu@gmail.com
> <https://web.facebook.com/sudara.yasi> <https://twitter.com/Sudaraka94>
> <https://www.linkedin.com/in/sudarakajayathilaka>
> <https://www.instagram.com/sudaraka94/>
>
>