package socket;

import java.io.*;
import java.net.Socket;

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("我是服务器,客户端说:" + info);
 }
 socket.shutdownInput();

 os = socket.getOutputStream();
 pw = new PrintWriter(os);
 pw.write("服务器欢迎你,这是你的幸运数字: " + (int) (Math.random() * 10000));
 pw.flush();
 } catch (Exception e) {
 e.printStackTrace();
 } 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();
 }
 }
 }
}