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.