Added MSG command (broadcast) to pixelwar

pixelwar/src/de/paws/pixelwar/NetCanvas.java

@@ -1,6 +1,7 @@
 package de.paws.pixelwar;
 
 import java.awt.AlphaComposite;
+import java.awt.Canvas;
 import java.awt.Color;
 import java.awt.Graphics;
 import java.awt.Graphics2D;
@@ -13,7 +14,7 @@ import java.awt.image.BufferedImage;
 
 import javax.swing.JFrame;
 
-public class Canvas {
+public class NetCanvas {
 	private volatile BufferedImage drawBuffer;
 	private volatile BufferedImage overlayBuffer;
 	private volatile BufferedImage paintBuffer;
@@ -21,8 +22,9 @@ public class Canvas {
 	private final BufferStrategy strategy;
 	private final Thread refresher;
 	private final JFrame frame;
+	private final Canvas canvas;
 
-	public Canvas() {
+	public NetCanvas() {
 
 		frame = new JFrame() {
 			private static final long serialVersionUID = 1L;
@@ -52,15 +54,21 @@ public class Canvas {
 			}
 		};
 
-		frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
-		frame.setUndecorated(true);
-		frame.setResizable(true);
-		frame.setSize(800, 600);
-		frame.setVisible(true);
-		frame.setAlwaysOnTop(true);
+		canvas = new Canvas();
+		canvas.setSize(800, 600);
 
-		frame.createBufferStrategy(2);
-		strategy = frame.getBufferStrategy();
+		frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
+		frame.setTitle("Pixelflut");
+		// frame.setUndecorated(true);
+		frame.setResizable(true);
+		// frame.setAlwaysOnTop(true);
+
+		frame.add(canvas);
+		frame.pack();
+		frame.setVisible(true);
+
+		canvas.createBufferStrategy(2);
+		strategy = canvas.getBufferStrategy();
 		resizeBuffer(1024, 1024);
 
 		refresher = new Thread(new Runnable() {

pixelwar/src/de/paws/pixelwar/PixelClientHandler.java

@@ -3,14 +3,48 @@ package de.paws.pixelwar;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
+import java.util.HashSet;
+import java.util.Set;
+
 public class PixelClientHandler extends SimpleChannelInboundHandler<String> {
 
-	private final Canvas canvas;
+	private static Set<PixelClientHandler> clients = new HashSet<>();
 
-	public PixelClientHandler(Canvas canvas) {
+	private final NetCanvas canvas;
+	private long connected;
+	private long c = 0;
+	private ChannelHandlerContext channel;
+
+	public PixelClientHandler(NetCanvas canvas) {
 		this.canvas = canvas;
 	}
 
+	@Override
+	public void channelActive(ChannelHandlerContext ctx) throws Exception {
+		super.channelActive(ctx);
+		this.connected = System.currentTimeMillis();
+		channel = ctx;
+		synchronized (clients) {
+			clients.add(this);
+		}
+	}
+
+	@Override
+	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+		super.channelActive(ctx);
+		long passed = System.currentTimeMillis() - connected;
+		System.out.print(c * 1000 / passed);
+		synchronized (clients) {
+			clients.remove(this);
+		}
+	}
+
+	public void writeIfPossible(String str) {
+		if (channel.channel().isWritable()) {
+			channel.writeAndFlush(str.trim() + "\n");
+		}
+	}
+
 	@Override
 	protected void channelRead0(ChannelHandlerContext ctx, String msg)
 			throws Exception {
@@ -21,6 +55,7 @@ public class PixelClientHandler extends SimpleChannelInboundHandler<String> {
 		String command = parts[0].toUpperCase();
 
 		if (command.equals("PX")) {
+			c++;
 			if (parts.length == 3) {
 				int x = Integer.parseInt(parts[1]);
 				int y = Integer.parseInt(parts[2]);
@@ -34,13 +69,23 @@ public class PixelClientHandler extends SimpleChannelInboundHandler<String> {
 				if (parts[3].length() == 6)
 					color += 0xff000000;
 				canvas.setPixel(x, y, color);
+			} else {
+				ctx.writeAndFlush("ERR\n");
+				ctx.close();
 			}
 		} else if (command.equals("SIZE")) {
-			ctx.write(String.format("SIZE %d %d\n", canvas.getWidth(),
+			ctx.writeAndFlush(String.format("SIZE %d %d\n", canvas.getWidth(),
 					canvas.getHeight()));
-			ctx.flush();
-		} else if (command.equals("TILE") && parts.length == 3) {
+		} else if (command.equals("MSG")) {
+			String text = command + " "
+					+ msg.substring(command.length()).trim();
+			for (PixelClientHandler c : clients) {
+				if (c != this)
+					c.writeIfPossible(text);
+			}
+		} else {
+			ctx.writeAndFlush("ERR\n");
+			ctx.close();
 		}
-
 	}
 }

pixelwar/src/de/paws/pixelwar/PixelServer.java

@@ -5,6 +5,7 @@ import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelHandlerAdapter;
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.ChannelOption;
+import io.netty.channel.ChannelPipeline;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
@@ -18,12 +19,12 @@ import io.netty.handler.logging.LoggingHandler;
 
 public class PixelServer extends ChannelHandlerAdapter {
 
-	private final Canvas canvas;
+	private final NetCanvas canvas;
 	private final int port;
 
 	public PixelServer(int port) {
 		this.port = port;
-		this.canvas = new Canvas();
+		this.canvas = new NetCanvas();
 	}
 
 	public void run() throws InterruptedException {
@@ -39,19 +40,17 @@ public class PixelServer extends ChannelHandlerAdapter {
 						@Override
 						public void initChannel(SocketChannel ch)
 								throws Exception {
+							ChannelPipeline p = ch.pipeline();
 
-							ch.pipeline().addLast(
-									"framer",
-									new DelimiterBasedFrameDecoder(128,
-											Delimiters.lineDelimiter()));
-							ch.pipeline().addLast("decoder",
-									new StringDecoder());
-							ch.pipeline().addLast("encoder",
-									new StringEncoder());
+							// p.addLast("logger", new LoggingHandler(
+							// LogLevel.DEBUG));
+							p.addLast("framer", new DelimiterBasedFrameDecoder(
+									128, Delimiters.lineDelimiter()));
+							p.addLast("decoder", new StringDecoder());
+							p.addLast("encoder", new StringEncoder());
 
 							// and then business logic.
-							ch.pipeline().addLast("handler",
-									new PixelClientHandler(canvas));
+							p.addLast("handler", new PixelClientHandler(canvas));
 						}
 					});