Hi,the code on github is what we used in the last production,and the code is more like a POC,but we use it in production and works well.
after I knew that akka is going to implement the akka remoting via akka stream and akka io.I reimplement it and split it to akka-io-netty and then implement the transport based on the io extension. in the new way I did not use the bootstrap and user event trigger and mainly implemented all the command what akka io tcp have,and I tried to implement the domain socket too. and it is more like an POC too,but we are using the new implement now. as the akka remoting is going to using akka stream and the akka stream it's self is based on the akka io extension,so I think this would be the right direction. one problem of the current SPI is that you don't know when to do a flush<write don't auto flush in netty4>,and you have to using a tick to do the flush or trigger a flush every time you do write akk writeAndFlush.And the current SPI is a little complicate too. 在 2015年6月15日星期一 UTC+8下午6:51:06，Guido Medina写道： > Hi Hepin, > > Thanks for your response, what does that mean exactly? > Is it your extension going a workaround for Akka remote or are you > actually talking about the new Akka remote? > > Best regards, > > Guido. > > On Monday, June 15, 2015 at 11:02:39 AM UTC+1, Patrik Nordwall wrote: >> >> 2.4-M2 should be out this week or early next week. >> >> We don't have an ETA of 2.4-RC yet, but we are working hard on making it >> happen as soon as possible. It might be possible in August, but I can't >> promise anything. >> >> /Patrik >> >> On Mon, Jun 15, 2015 at 7:12 AM, 何品 <[email protected]> wrote: >> >>> I have build a new one via io extension,and maybe opensource when it is >>> more complete. >>> the code there is deprecated. >>> and I will try to build the io extension via akka stream too. >>> >>> ``` >>> >>> import java.net.InetSocketAddress >>> >>> import akka.actor.{ Actor, ActorLogging, Props } >>> import akka.io.IO >>> import qgame.akka.extension.netty.transport.tcp.Tcp >>> import qgame.akka.extension.netty.transport.{ Bind, Bound, Connected } >>> >>> /** >>> * Created by kerr. >>> */ >>> class ServerActor extends Actor with ActorLogging { >>> >>> override def receive: Receive = { >>> case Bound(address) => >>> log.debug("bound :[{}]", address) >>> case Connected(remoteAddress, localAddress) => >>> val connector = sender() >>> log.debug("connected,remote :[{}],local :[{}],connector :[{}]", >>> remoteAddress, localAddress, connector) >>> context.actorOf(Props.create(classOf[ConnectionHandler], connector, >>> remoteAddress, localAddress)) >>> >>> } >>> >>> @throws[Exception](classOf[Exception]) >>> override def preStart(): Unit = { >>> import context.system >>> val manager = IO(Tcp) >>> manager ! Bind(self, new InetSocketAddress(9000)) >>> super.preStart() >>> } >>> } >>> >>> ``` >>> 在 2015年6月14日星期日 UTC+8上午4:07:05，Guido Medina写道： >>> >>>> Also, I would like to know what's the status of the new Akka remote >>>> using Akka I/O, I was trying to use the Netty 4 implementation from Hepin: >>>> https://github.com/hepin1989/akka-remote-transport-netty4 >>>> >>>> But I just realized it was deprecated in favor of the new Akka I/O. >>>> >>>> Best regards, >>>> >>>> Guido. >>>> >>>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: >>> http://doc.akka.io/docs/akka/current/additional/faq.html >>> >>>>>>>>>> Search the archives: >>> https://groups.google.com/group/akka-user >>> --- >>> You received this message because you are subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to [email protected]. >>> To post to this group, send email to [email protected]. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> >> Patrik Nordwall >> Typesafe <http://typesafe.com/> - Reactive apps on the JVM >> Twitter: @patriknw >> >> -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
