java网络编程部分代码

chenxinxiner · chenxinxiner · commit b66f3f520a3d · 2020-04-02T21:07:40.000+08:00
diff --git a/src/main/java/Maintest.java b/src/main/java/Maintest.java
@@ -0,0 +1,52 @@
+import java.io.File;
+import java.lang.reflect.InvocationTargetException;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Queue;
+
+/**
+ * @author ：chenxin
+ * @date ：Created in 2020/3/28 12:20
+ * @description：
+ * @modified By：
+ * @version: $
+ */
+public class Maintest {
+
+
+    public static void main(String[] args) throws MalformedURLException, ClassNotFoundException, NoSuchMethodException, IllegalAccessException, InvocationTargetException, InstantiationException {
+        final URL resource = Maintest.class.getResource("");
+        System.out.println(resource);
+
+        int offset = Maintest.class.getResource("/").getPath().length();
+
+        Queue<File> files = new LinkedList<>();
+        files.add(new File(resource.getFile()));
+        List<Object> beans = new ArrayList<>();
+
+        while (!files.isEmpty()) {
+            File tmp = files.poll();
+            for (File f : tmp.listFiles()) {
+                if (f.isDirectory()) {
+                    files.add(f);
+                } else {
+                    if (f.getName().endsWith(".class")) {
+
+                        String clsName = f.toURI().toURL().getPath().substring(offset).replaceAll("/", ".").replace(".class", "");
+                        System.out.println(clsName);
+                        final Class<?> aClass = Maintest.class.getClassLoader().loadClass(clsName);
+                        if (!aClass.isInterface()) {
+                            beans.add(aClass.getConstructor().newInstance());
+                        }
+                    }
+                }
+            }
+        }
+
+        System.out.println(offset);
+        System.out.println();
+    }
+}
diff --git a/src/main/java/netWork/tcp/TcpClient.java b/src/main/java/netWork/tcp/TcpClient.java
@@ -0,0 +1,49 @@
+package netWork.tcp;
+
+import java.io.*;
+import java.net.InetAddress;
+import java.net.Socket;
+
+/**
+ * TCP客户端
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 21:17
+ * @description：TCP客户端
+ * @modified By：
+ * @version: $
+ */
+public class TcpClient {
+
+    public static void main(String[] args) throws Exception {
+        //需要服务器端先开启
+        Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 8002);
+        //同一个通道，服务端的输出流就是客户端的输入流，服务端的输入流就是客户端的输出流
+        InputStream inputStream = socket.getInputStream();
+        BufferedReader brNet = new BufferedReader(new InputStreamReader(inputStream));
+
+        //开启通道的输出流
+        OutputStream ops = socket.getOutputStream();
+        DataOutputStream dos = new DataOutputStream(ops);
+        final BufferedReader brKey = new BufferedReader(new InputStreamReader(System.in));
+        while (true) {
+            String strWord = brKey.readLine();
+            if ("quit".equalsIgnoreCase(strWord)) {
+                break;
+            } else {
+                System.out.println("I want to send " + strWord);
+                dos.writeBytes(strWord + System.getProperty("line.separator"));
+                System.out.println("Server said " + brNet.readLine());
+            }
+
+        }
+
+        dos.close();
+        ops.close();
+        brNet.close();
+        inputStream.close();
+        socket.close();
+
+
+    }
+}
diff --git a/src/main/java/netWork/tcp/TcpServer.java b/src/main/java/netWork/tcp/TcpServer.java
@@ -0,0 +1,45 @@
+package netWork.tcp;
+
+import java.io.*;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+/**
+ * tcp服务器端
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 21:11
+ * @description：tcp服务器端
+ * @modified By：
+ * @version: $
+ */
+public class TcpServer {
+    public static void main(String[] args) {
+        try {
+            //创建一个绑定到8001端口的TCP服务器
+            ServerSocket ss = new ServerSocket(8001);
+            //开启监听
+            Socket s = ss.accept();
+
+            System.out.println("Welcome to Java world");
+            //有人连上来，打开输入流
+            InputStream ins = s.getInputStream();
+            //打开输出流
+            OutputStream ops = s.getOutputStream();
+
+            ops.write("Hello ,Client!".getBytes());
+
+            BufferedReader br = new BufferedReader(new InputStreamReader(ins));
+
+            System.out.println("Client said: " + br.readLine());
+
+            ins.close();
+            ops.close();
+            s.close();
+            ss.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+}
diff --git a/src/main/java/netWork/tcp/TcpServerConcurrent.java b/src/main/java/netWork/tcp/TcpServerConcurrent.java
@@ -0,0 +1,31 @@
+package netWork.tcp;
+
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * TCP服务端可以处理多个请求
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 21:33
+ * @description：TCP服务端可以处理多个请求
+ * @modified By：
+ * @version: $
+ */
+public class TcpServerConcurrent {
+    public static void main(String[] args) {
+        try {
+            ServerSocket ss = new ServerSocket(8002);
+            final ExecutorService executorService = Executors.newCachedThreadPool();
+            while (true) {
+                final Socket s = ss.accept();
+                System.out.println("来了一个client");
+                executorService.submit(new Worker(s));
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/src/main/java/netWork/tcp/Worker.java b/src/main/java/netWork/tcp/Worker.java
@@ -0,0 +1,55 @@
+package netWork.tcp;
+
+import java.io.*;
+import java.net.Socket;
+
+/**
+ * 每个socket的工作
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 21:38
+ * @description：每个socket的工作
+ * @modified By：
+ * @version: $
+ */
+public class Worker implements Runnable {
+
+    private Socket socket;
+
+    public Worker(Socket socket) {
+        this.socket = socket;
+    }
+
+    @Override
+    public void run() {
+        try {
+            System.out.println("服务人员已启动");
+            //同一个通道，服务端的输出流就是客户端的输入流，服务端的输入流就是客户端的输出流
+            InputStream ips = socket.getInputStream();
+            BufferedReader br = new BufferedReader(new InputStreamReader(ips));
+
+            //开启通道的输出流
+            OutputStream ops = socket.getOutputStream();
+            DataOutputStream dos = new DataOutputStream(ops);
+
+            while (true) {
+                String s = br.readLine();
+                System.out.println("client said :" + s + ":" + s.length());
+                if ("quit".equalsIgnoreCase(s)) {
+                    break;
+                }
+                String strEcho = s + " 666";
+                System.out.println("server said:" + strEcho + " :" + strEcho.length());
+                dos.writeBytes(s + "--->" + strEcho + System.getProperty("line.separator"));
+            }
+            br.close();
+            dos.close();
+            ops.close();
+            ips.close();
+            socket.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+}
diff --git a/src/main/java/netWork/udp/UdpSend.java b/src/main/java/netWork/udp/UdpSend.java
@@ -0,0 +1,44 @@
+package netWork.udp;
+
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+
+/**
+ * upd发送
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 20:13
+ * @description：upd发送
+ * @modified By：
+ * @version: $
+ */
+public class UdpSend {
+
+    public static void main(String[] args) throws Exception {
+        DatagramSocket ds = new DatagramSocket();
+
+        String str = "hello world";
+
+        final DatagramPacket datagramPacket = new DatagramPacket(str.getBytes(), str.length(), InetAddress.getByName("127.0.0.1"), 3000);
+        System.out.println("UdpSend：我要发信息");
+        ds.send(datagramPacket);
+        System.out.println("UdpSend:我发送消息结束");
+
+        Thread.sleep(1000);
+
+        byte[] buf = new byte[1024];
+        DatagramPacket dp2 = new DatagramPacket(buf, 1024);
+        System.out.println("UdpSend:我等待接收信息");
+        ds.receive(dp2);
+        System.out.println("UdpSend:我接收到消息");
+
+        String strRecv = new String(dp2.getData(), 0, dp2.getLength()) +
+                " from " + dp2.getAddress().getHostAddress() + ":" + dp2.getPort();
+
+        System.out.println(strRecv);
+
+        ds.close();
+
+    }
+}
diff --git a/src/main/java/netWork/udp/UpdRecv.java b/src/main/java/netWork/udp/UpdRecv.java
@@ -0,0 +1,42 @@
+package netWork.udp;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+import java.net.SocketException;
+
+/**
+ * UDP协议接收方
+ *
+ * @author ：chenxin
+ * @date ：Created in 2020/3/29 20:05
+ * @description：UDP协议接收方
+ * @modified By：
+ * @version: $
+ */
+public class UpdRecv {
+    public static void main(String[] args) throws Exception {
+        DatagramSocket ds = new DatagramSocket(3000);
+        byte[] buf = new byte[1024];
+        DatagramPacket dp = new DatagramPacket(buf, 1024);
+
+        System.out.println("UdpRecv:我在等待消息");
+        ds.receive(dp);
+        System.out.println("UdpRecv:我接收到消息");
+
+        String strRecv = new String(dp.getData(), 0, dp.getLength()) +
+                " from " + dp.getAddress().getHostAddress() + ":" + dp.getPort();
+
+        System.out.println(strRecv);
+
+        Thread.sleep(1000);
+        System.out.println("UdpRecv:我要发送消息");
+        String str = "hello world 222";
+        final DatagramPacket datagramPacket = new DatagramPacket(str.getBytes(), str.length(), InetAddress.getByName("127.0.0.1"), dp.getPort());
+        ds.send(datagramPacket);
+        System.out.println("UdpRecv:我发送消息结束");
+        ds.close();
+
+    }
+}
