Merge branch 'dev'

Author: silently9527

Algorithms/src/main/java/cn/silently9527/unionfind/AbstractUF.java

@@ -0,0 +1,25 @@
+package cn.silently9527.unionfind;
+
+public abstract class AbstractUF implements UF {
+    protected int[] id;
+    protected int count;
+
+    public AbstractUF(int N) {
+        count = N;
+
+        id = new int[N];
+        for (int i = 0; i < N; i++) {
+            id[i] = i;
+        }
+    }
+
+    @Override
+    public boolean connected(int p, int q) {
+        return find(p) == find(q);
+    }
+
+    @Override
+    public int count() {
+        return count;
+    }
+}

Algorithms/src/main/java/cn/silently9527/unionfind/QuickFindImpl.java

@@ -0,0 +1,30 @@
+package cn.silently9527.unionfind;
+
+public class QuickFindImpl extends AbstractUF {
+    public QuickFindImpl(int N) {
+        super(N);
+    }
+
+    @Override
+    public int find(int p) {
+        return id[p];
+    }
+
+    @Override
+    public void union(int p, int q) {
+        int pId = find(p);
+        int qId = find(q);
+
+        if (pId == qId) { //如果相等表示p与q已经属于同一分量中
+            return;
+        }
+
+        for (int i = 0; i < id.length; i++) {
+            if (id[i] == pId) {
+                id[i] = qId; //把分量中所有的值都统一成qId
+            }
+        }
+        count--; //连通分量数减一
+    }
+
+}

Algorithms/src/main/java/cn/silently9527/unionfind/QuickUnionImpl.java

@@ -0,0 +1,28 @@
+package cn.silently9527.unionfind;
+
+public class QuickUnionImpl extends AbstractUF {
+    public QuickUnionImpl(int N) {
+        super(N);
+    }
+
+    @Override
+    public int find(int p) {
+        //找出p所在分量的根触点
+        while (p != id[p]) {
+            p = id[p];
+        }
+        return p;
+    }
+
+    @Override
+    public void union(int p, int q) {
+        int pRoot = find(p); //找出q p的根触点
+        int qRoot = find(q);
+        if (pRoot == qRoot) { //处于同一分量不做处理
+            return;
+        }
+        id[pRoot] = qRoot; //根节点
+        count--;
+    }
+
+}

Algorithms/src/main/java/cn/silently9527/unionfind/UF.java

@@ -0,0 +1,11 @@
+package cn.silently9527.unionfind;
+
+public interface UF {
+    void union(int p, int q); //在p与q之间添加一条连接
+
+    int find(int p); //找出p所在分量的标识符
+
+    boolean connected(int p, int q); //判断出p与q是否存在于同一个分量中
+
+    int count(); //统计出连通分量的数量
+}

Algorithms/src/main/java/cn/silently9527/unionfind/WeightedQuickUnionImpl.java

@@ -0,0 +1,40 @@
+package cn.silently9527.unionfind;
+
+public class WeightedQuickUnionImpl extends AbstractUF {
+    private int[] sz;
+
+    public WeightedQuickUnionImpl(int N) {
+        super(N);
+        sz = new int[N];
+        for (int i = 0; i < N; i++) {
+            sz[i] = 1;
+        }
+    }
+
+    @Override
+    public void union(int p, int q) {
+        int pRoot = find(p); //找出q p的根触点
+        int qRoot = find(q);
+        if (pRoot == qRoot) { //处于同一分量不做处理
+            return;
+        }
+        //小树合并到大树
+        if (sz[pRoot] < sz[qRoot]) {
+            sz[qRoot] += sz[pRoot];
+            id[pRoot] = qRoot;
+        } else {
+            sz[pRoot] += sz[qRoot];
+            id[qRoot] = pRoot;
+        }
+        count--;
+    }
+
+    @Override
+    public int find(int p) {
+        //找出p所在分量的根触点
+        while (p != id[p]) {
+            p = id[p];
+        }
+        return p;
+    }
+}

Netty/pom.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>cn.silently9527</groupId>
+    <artifactId>Netty</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.51.Final</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>

Netty/src/main/java/cn/silently9527/netty/EchoClient.java

@@ -0,0 +1,43 @@
+package cn.silently9527.netty;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+
+public class EchoClient {
+    private final String host;
+    private final int port;
+
+    public EchoClient(String host, int port) {
+        this.host = host;
+        this.port = port;
+    }
+
+    public void start() throws InterruptedException {
+        EventLoopGroup group = new NioEventLoopGroup();
+        try {
+            Bootstrap bootstrap = new Bootstrap();
+            bootstrap.group(group)
+                    .channel(NioSocketChannel.class)
+                    .remoteAddress(host, port)
+                    .handler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel ch) throws Exception {
+                            ch.pipeline().addLast(new EchoClientHandler());
+                        }
+                    });
+            ChannelFuture future = bootstrap.connect().sync();
+            future.channel().closeFuture().sync();
+        } finally {
+            group.shutdownGracefully().sync();
+        }
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        new EchoClient("localhost", 8080).start();
+    }
+}

Netty/src/main/java/cn/silently9527/netty/EchoClientHandler.java

@@ -0,0 +1,26 @@
+package cn.silently9527.netty;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+import io.netty.util.CharsetUtil;
+
+public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        ctx.writeAndFlush(Unpooled.copiedBuffer("Hello, I am a client", CharsetUtil.UTF_8));
+    }
+
+    @Override
+    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
+        System.out.println("Client received:" + msg.toString(CharsetUtil.UTF_8));
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}

Netty/src/main/java/cn/silently9527/netty/EchoServer.java

@@ -0,0 +1,45 @@
+package cn.silently9527.netty;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+
+public class EchoServer {
+    private final int port;
+
+    public EchoServer(int port) {
+        this.port = port;
+    }
+
+    public void start() throws InterruptedException {
+        EchoServerHandler echoServerHandler = new EchoServerHandler();
+        EventLoopGroup group = new NioEventLoopGroup();
+
+        try {
+            ServerBootstrap bootstrap = new ServerBootstrap();
+            bootstrap.group(group)
+                    .channel(NioServerSocketChannel.class)
+                    .localAddress(port)
+                    .childHandler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel ch) throws Exception {
+                            ch.pipeline().addLast(echoServerHandler);
+                        }
+                    });
+            ChannelFuture channelFuture = bootstrap.bind().sync();
+            channelFuture.channel().closeFuture().sync();
+        } finally {
+            group.shutdownGracefully().sync();
+        }
+
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        new EchoServer(8080).start();
+    }
+
+}

Netty/src/main/java/cn/silently9527/netty/EchoServerHandler.java

@@ -0,0 +1,31 @@
+package cn.silently9527.netty;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.CharsetUtil;
+
+public class EchoServerHandler extends ChannelInboundHandlerAdapter {
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ByteBuf byteBuf = (ByteBuf) msg;
+        System.out.println("Server received:" + byteBuf.toString(CharsetUtil.UTF_8));
+        ctx.write(byteBuf);
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)
+                .addListener(ChannelFutureListener.CLOSE);
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        ctx.close();
+    }
+
+}