socket

Author: durongze

callc/java/ServerThread.java

@@ -0,0 +1,60 @@
+package mypkg;
+
+import java.io.*;
+import java.net.*;
+
+public class ServerThread extends Thread{
+	
+	private Socket socket = null;
+	
+	public ServerThread(Socket socket) {
+		this.socket = socket;
+	}
+ 
+	@Override
+	public void run() {
+		InputStream is=null;
+        InputStreamReader isr=null;
+        BufferedReader br=null;
+        OutputStream os=null;
+        PrintWriter pw=null;
+        try {
+			is = socket.getInputStream();
+			isr = new InputStreamReader(is);
+			br = new BufferedReader(isr);
+			
+			String info = null;
+			
+			while((info=br.readLine())!=null){
+				System.out.println("svr,cli:"+info);
+			}
+			socket.shutdownInput();
+			
+			os = socket.getOutputStream();
+			pw = new PrintWriter(os);
+			pw.write("服务器欢迎你");
+			
+			pw.flush();
+        } catch (Exception e) {
+			// TODO: handle exception
+		} finally{
+            try {
+                if(pw!=null)
+                    pw.close();
+                if(os!=null)
+                    os.close();
+                if(br!=null)
+                    br.close();
+                if(isr!=null)
+                    isr.close();
+                if(is!=null)
+                    is.close();
+                if(socket!=null)
+                    socket.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+		}
+	}
+ 
+}

callc/java/SocketClient.java

@@ -0,0 +1,33 @@
+package mypkg;
+import java.net.*;
+import java.io.*;
+
+public class SocketClient {
+	
+	public static void main(String[] args) throws InterruptedException {
+		try {
+			Socket socket = new Socket("localhost",8088);
+			OutputStream os = socket.getOutputStream();
+			PrintWriter pw = new PrintWriter(os);
+			pw.write(" cli msg");
+			pw.flush();
+			
+			socket.shutdownOutput();
+			
+			InputStream is = socket.getInputStream();
+			BufferedReader br = new BufferedReader(new InputStreamReader(is));
+			String info = null;
+			while((info = br.readLine())!=null){
+				System.out.println("cli rcv:"+info);
+			}
+			
+			br.close();
+			is.close();
+			os.close();
+			pw.close();
+			socket.close();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+}

callc/java/SocketServer.java

@@ -0,0 +1,26 @@
+package mypkg;
+import java.net.*;
+import java.io.*;
+
+public class SocketServer {
+	
+	public static void main(String[] args) {
+		try {
+			ServerSocket serverSocket = new ServerSocket(8088);
+			Socket socket = new Socket();	
+			
+            while(true){
+            	socket = serverSocket.accept();
+            	
+            	ServerThread thread = new ServerThread(socket);
+            	thread.start();
+            	
+            	InetAddress address=socket.getInetAddress();
+                System.out.println("cli ip:"+address.getHostAddress());
+            }
+		} catch (Exception e) {
+			// TODO: handle exception
+			e.printStackTrace();
+		}
+	}
+}

callc/java/build.bat

@@ -3,7 +3,7 @@
 set JAVA_HOME=D:\Program Files\Java\jdk-12.0.2
 set PATH=%PATH%;%JAVA_HOME%\bin;
 
-set srcs=ForScanner.java ForScannerChild.java TxtParseUtils.java
+set srcs=ForScanner.java ForScannerChild.java TxtParseUtils.java ServerThread.java SocketClient.java SocketServer.java
 
 for %%i in (%srcs%) do (
     javac -encoding utf-8 -h . %%i
@@ -13,5 +13,10 @@ for %%i in (%srcs%) do (
         echo %%i succ.................................
     )
 )
+
+mkdir mypkg
 move *.class mypkg
+
+java mypkg.SocketServer
+
 :proc_err