服务器线程.txt

java写的一个能实现自动刷新的聊天程序

package day15.chat;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;

public class ServerThread extends Thread{
        private Socket so;
        private static String word="";
        public ServerThread(Socket so){
                this.so=so;
        }
        public void run(){
                System.out.println("stop");
           try{
                InputStreamReader isr =  new InputStreamReader(so.getInputStream());
                BufferedReader br=new BufferedReader(isr);//读
                PrintStream ps = new PrintStream(so.getOutputStream());
                while(true){
                        String temp = br.readLine();
                        if("\u0000".equals(temp)){//如果是刷新指令
                                ps.println("From Server:"+word);//写回
                        }else{//客户的消息
                                System.out.println(temp);
                                if("bye".equals(temp)){
                                        break;
                                }
                                word=temp+"\u0001"+word;
                                ps.println("From Server:"+word);//写回
                        }
                        
                }
                br.close();
                isr.close();
                ps.close();
                so.close();
           } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
}