Java连载127-多线程TCP网络编程

package com.bjpowernode.java_learning;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;
import java.util.Scanner;

public class D127_1_ClientTest {
 public static void main(String[] args) {
  Scanner scanner = new Scanner(System.in);
  String input = null;
  Socket socket = null;
  DataInputStream in = null;
  DataOutputStream out = null;
  String serverIP = "127.0.0.1";                           //服务器端IP
  int port = 5050;
  
  try {
   socket = new Socket(serverIP,port);                  //连接服务器
   in = new DataInputStream(socket.getInputStream());   //创建输入流
   out = new DataOutputStream(socket.getOutputStream());//创建输出流
   System.out.println("请输入一个待计算的四则运算表达式");
   
   while(scanner.hasNext()) {
    input = scanner.nextLine();                       //从键盘输入一个待计算的四则运算表达式
    if(!input.contentEquals("0")) {
     out.writeUTF(input);                          //向服务器发送运算请求
     String result = in.readUTF();                 //等待读取运算结果
     System.out.println("服务器返回的计算结果："+result);
     System.out.println("请输入一个正整数的四则运算表达式（输入0退出）：");
     
    }else {
     break;                                        //请求结果
    }
   }
  }catch(Exception e) {
   System.out.println("与服务器连接中断");
  }finally {
   try {
    in.close();                                       //关闭网络连接
    out.close();
    socket.close();
    System.out.println("连接结束");
   }catch(Exception e) {
    
   }
  }
 }
}

package com.bjpowernode.java_learning;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import com.bjpowernode.java_learning.D127_3_ThreadTest;

public class D127_2_ServerTest {
 public static void main(String[] args) {
  ServerSocket server_socket = null;
  Socket socket = null;
  int port = 5050;
  
  while(true) {
   try {
    server_socket = new ServerSocket(port);
    System.out.println("服务器启动！");
   }catch(IOException e1) {
    System.out.println("正在监听");                   //ServerSocket对象不能重复创建
   }
   
   try {
    System.out.println("等待客户请求！");
    socket = server_socket.accept();
    System.out.println("客户的地址："+socket.getInetAddress() + ":" + socket.getPort());
   }catch(IOException e) {
    System.out.println("正在等待客户"); 
   }
   
   if(socket!=null) {
    new D127_3_ThreadTest(socket);                          //为每个客户启动一个专门的线程
   }
  }
 }
}

package com.bjpowernode.java_learning;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;

public class D127_3_ThreadTest extends Thread {
 Socket socket = null;
 DataInputStream in = null;
 DataOutputStream out = null;
 String str;
 String response;
 String ip;
 int port;
 
 public D127_3_ThreadTest(Socket socket) {
  this.socket = socket;
  start();
 }
 
 public void run() {
  try {
   in = new DataInputStream(socket.getInputStream());          //创建输入流
   out = new DataOutputStream(socket.getOutputStream());       //创建输出流
   ip = socket.getInetAddress().getHostAddress();              //客户端IP地址
   port = socket.getPort();                                    //客户端的端口号
   
   while(true) {
    str = in.readUTF();                                     //获取客户端的表达式
    System.out.println("客户端" + ip + ":" + port + "发送的请求内容：");
    System.out.println(str+"=?");
    
    if(str.contentEquals("0")) {
     System.out.println("连接结束");
     break;
    }else {
     response = doComputer(str);                         //对表达式进行计算
     out.writeUTF(response);                             //响应计算结果
    }   
   }  
  }catch(Exception e) {
   System.out.println("连接结束");
  }finally {
   try {
    in.close();
    out.close();
    socket.close();
   }catch(Exception e) {
    
   }
  }
 }
 public String doComputer(String str) {
  String input;
  String[] sym;
  String[] data;
  int a=0,b=0,result=0;
  input = str;
  data = input.split("\\D+");
  sym = input.split("\\d+");
  a = Integer.parseInt(data[0]);
  b = Integer.parseInt(data[1]);
  
  try {
   switch(sym[1]) {
   case "+":
    result = a + b;
    break;
   case "-":
    result = a - b;
    break;
   case "*":
    result = a * b;
    break;
   case "/":
    result = a / b;
   }
   System.out.println("计算结果："+input+"="+result);
   return String.valueOf(result);
  }catch(java.lang.ArithmeticException e) {
   System.out.println("数据错误！");
   return "数据错误";
  }
 }

}