the problem is solved.... 在 2016年2月3日星期三 UTC+8下午3:26:19，Wong Hoi Fung写道： > > I also asked this question in > http://stackoverflow.com/questions/35168660/akka-java-tcp-chatroom > > I tried to extend the code about TCP in doc to make a simple chat room, > simply put, several clients connected to server, one client send a string, > server broadcast the string to all clients...the code I wrote showed below, > it doesn't work, can someone tell why? > > > the program behave wrong, say 2 clients connected to server, one send a > message, then the sender get 2 messages back, the other get nothing... > > > Main.java > > public class Main { > public static void main(String[] args) { > akka.Main.main(new String[] { Server.class.getName()}); > }} > > > Server.java > > public class Server extends UntypedActor { > > final ActorRef manager = Tcp.get(getContext().system()).manager(); > > public static Props props(ActorRef manager) { > return Props.create(Server.class, manager); > } > > @Override > public void preStart() throws Exception { > final ActorRef tcp = Tcp.get(getContext().system()).manager(); > tcp.tell(TcpMessage.bind(getSelf(), new InetSocketAddress("0.0.0.0", > 8888), 100), getSelf()); > } > > @Override > public void onReceive(Object msg) throws Exception { > if (msg instanceof Bound) { > manager.tell(msg, getSelf()); > > } else if (msg instanceof CommandFailed) { > getContext().stop(getSelf()); > > } else if (msg instanceof Connected) { > final Connected conn = (Connected) msg; > manager.tell(conn, getSelf()); > final ActorRef handler = > getContext().actorOf(Props.create(SimplisticHandler.class)); > getContext().system().eventStream().subscribe(handler, > Notification.class); > getSender().tell(TcpMessage.register(handler), getSelf()); > } > } > } > > > SimplisticHandler.java > > public class SimplisticHandler extends UntypedActor { > @Override > public void onReceive(Object msg) throws Exception { > if (msg instanceof Received) { > > final ByteString data = ((Received) msg).data(); > System.out.println(data); > getContext().system().eventStream().publish(new > Notification(getSender(), getSelf(), 1, data)); > > } else if (msg instanceof ConnectionClosed) { > > getContext().stop(getSelf()); > > } else if (msg instanceof Notification) { > > Notification noti = (Notification)msg; > // TODO while the below statement don't broadcast ? > if (noti.id == 1) > noti.sender.tell(TcpMessage.write((ByteString)(noti.obj)), getSelf()); > > } > }} > > > Notification.java > > public class Notification { > public final ActorRef sender; > public final ActorRef receiver; > public final int id; > public final Object obj; > > public Notification(ActorRef sender, ActorRef receiver, int id, Object > obj) { > this.sender = sender; > this.receiver = receiver; > this.id = id; > this.obj = obj; > }} > > > >
-- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
