java - Netty trouble with chat server -

-

i'm having trouble figuring out wrong simple netty chat program working with.

i have tried debugging through program hasn't been able show me problem lies.

through debugging seems client connecting server, write function doesn't seem working.

i followed tutorial here. have source code here on github.

here client classes.

public void run() throws exception {     eventloopgroup group = new nioeventloopgroup();      try {         bootstrap bootstrap = new bootstrap()             .group(group)             .channel(niosocketchannel.class)             .handler(new chatclientinitializer());          channel channel = bootstrap.connect(host, port).sync().channel();         bufferedreader in = new bufferedreader(new inputstreamreader(system.in));          while (true) {             channel.write(in.readline() + "\r\n");         }      } {         group.shutdowngracefully();     } }  public class chatclientinitializer extends channelinitializer<socketchannel> {      @override     protected void initchannel(socketchannel ch) throws exception {      channelpipeline pipeline = ch.pipeline();      pipeline.addlast("framer", new delimiterbasedframedecoder(8192,delimiters.linedelimiter()));         pipeline.addlast("decoder", new stringdecoder());         pipeline.addlast("encoder", new stringencoder());         pipeline.addlast("handler", new chatclienthandler());     } }  public class chatclienthandler extends simplechannelinboundhandler<string>{       @override     protected void channelread0(channelhandlercontext ctx, string msg) throws exception {     system.out.println(msg);     } }

and here server classes

public void run() throws exception{     eventloopgroup bossgroup = new nioeventloopgroup();     eventloopgroup workergroup = new nioeventloopgroup();      try{         serverbootstrap bootstrap = new serverbootstrap()             .group(bossgroup,workergroup)             .channel(nioserversocketchannel.class)             .childhandler(new chatserverinitializer());          bootstrap.bind(port).sync().channel().closefuture().sync();     } {         bossgroup.shutdowngracefully();         workergroup.shutdowngracefully();     } }  public class chatserverinitializer extends channelinitializer<socketchannel> {      @override     protected void initchannel(socketchannel ch) throws exception {      channelpipeline pipeline = ch.pipeline();          pipeline.addlast("framer", new delimiterbasedframedecoder(8192, delimiters.linedelimiter()));         pipeline.addlast("decoder", new stringdecoder());     pipeline.addlast("encoder", new stringencoder());      pipeline.addlast("handler", new chatserverhandler());     }  }  public class chatserverhandler extends simplechannelinboundhandler<string>{  private static final channelgroup channels = new defaultchannelgroup(globaleventexecutor.instance);      @override     public void handleradded(channelhandlercontext ctx) throws exception{     channel incoming = ctx.channel();      channels.add(ctx.channel());          for(channel channel : channels){         channel.write("[server] - " + incoming.remoteaddress() + "has joined\n");         }     }      @override     public void handlerremoved(channelhandlercontext ctx) throws exception {     channel leaving = ctx.channel();           for(channel channel : channels){         channel.write("[server] - " + leaving.remoteaddress() + "has left\n");         }     channels.remove(ctx.channel());     }      @override     protected void channelread0(channelhandlercontext ctx, string msg)         throws exception {     channel incoming = ctx.channel();     system.out.println(msg);          for(channel channel : channels){         channel.write("[" + incoming.remoteaddress() + "]" + msg +"\n");             }        }  }

you need replace channel.write(...) channel.writeandflush(...)


Comments

Post a Comment

Popular posts from this blog

c# - Unity IoC Lifetime per HttpRequest for UserStore -

-
i'm trying clean default implementation of accountcontroller.cs comes out of box in new mvc5/owin security implementation. have modified constructor this: private usermanager<applicationuser> usermanager; public accountcontroller(usermanager<applicationuser> usermanager) { this.usermanager = usermanager; } also, have created lifetime manager unity looks this: public class httpcontextlifetimemanager<t> : lifetimemanager, idisposable { private httpcontextbase _context = null; public httpcontextlifetimemanager() { _context = new httpcontextwrapper(httpcontext.current); } public httpcontextlifetimemanager(httpcontextbase context) { if (context == null) throw new argumentnullexception("context"); _context = context; } public void dispose() { this.removevalue(); } public override object get...
Read more

Change the color of an oval at click in Java AWT -

-
i have draw ovals in java, , @ click change color. beginning tried change color after 20 ms, doesn't work. my code is: public class mycomponentnew extends frame { public graphics2d g2d; public mycomponentnew(string title) { super(title); setsize(400, 550); } @override public void paint(graphics g) { this.g2d = (graphics2d) g; this.g2d.setcolor(color.red); this.g2d.filloval(10, 55, 50, 100); } public void changecolor () { this.g2d.setcolor(color.blue); this.g2d.filloval(10, 55, 50, 100); } } and in class main method have: mycomponentnew m; m = new mycomponentnew("fereastra cu baloane"); m.setvisible(true); m.addwindowlistener(new windowadapter() { @override public void windowclosing(windowevent we) { system.exit(0); } }); try { thread.sleep(20); } catch(interruptedexception e) {} m.changecolor(); the color of oval remains red. ...
Read more

I am trying to solve the error message 'incompatible ranks 0 and 1 in assignment' in a fortran 95 program. -

-
i writing program in fortran find velocity of parachuting person in relation time. keep getting error can't fix. new programming , appreciated. the error is v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) 1 error: incompatible ranks 0 , 1 in assignment @ (1) and program is program para integer :: real :: v(11) !velocity real :: q !initial velocity real :: h !time step real :: c !drag coefficient real :: m !mass ! gravity equal 32 ft/s^2 write (*,*)'enter time step' read(*,*)h write(*,*)'enter initial velocity' read(*,*)q write(*,*)'enter drag coefficient' read(*,*)c write(*,*)'enter mass' read(*,*)m i=1,10 ! 1 10, 1 being interval. end v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) q=v(1) end program you cannot use [] normal parenthesis in expressions. array constructor, [ items ] means array items elements. end do should after line.
Read more