Java Socket共享的设计原理深层透析

欢迎进入Java社区论坛，与200万技术人员互动交流 >>进入

　　24.//— CreateServerThread

　　25.class CreateServerThread extends Thread

　　26.{

　　27.private Socket client;

　　28.private BufferedReader in;

　　29.private PrintWriter out;

　　30.public CreateServerThread(Socket s) throws IOException

　　31.{

　　32.client = s;

　　33.in = new BufferedReader(new InputStreamReader(client.getInputStream(), “GB2312”));

　　34.out = new PrintWriter(client.getOutputStream(), true);

　　35.out.println(“— Welcome —“);

　　36.start();

　　37.}

　　38.public void run()

　　39.{

　　40.try

　　41.{

　　42.String line = in.readLine();

　　43.while (!line.equals(“bye”))

　　44.{

　　45.String msg = createMessage(line);

　　46.out.println(msg);

　　47.line = in.readLine();

　　48.}

　　49.out.println(“— See you, bye! —“);

　　50.client.close();

　　51.}

　　52.catch (IOException e)

　　53.{}

　　54.}

　　55.private String createMessage(String line)

　　56.{

　　57.xxxxxxxxx;

　　58.}

　　59.}

　　60.public static void main(String[] args) throws IOException

　　61.{

　　62.new Server();

　　63.}

　　64.}

　　这个程序监听10000端口，并将接入交给CreateServerThread线程运行。CreateServerThread线程接受输入，并将输入回应客户，直到客户输入”bye”，线程结束。我们可以在createMessage方法中，对输入进行处理，并产生结果，然后把结果返回给客户。

[1][2]

这一生我只牵你的手，因为今生有你早已足够。