package socket;

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

public class ClientThread extends Thread{
 private Socket socket;

 public ClientThread() {
 try {
 Socket socket = new Socket("localhost", 8088);
 this.socket = socket;
 } catch (IOException e) {
 e.printStackTrace();
 }
 }

 public ClientThread(Socket socket) {
 this.socket = socket;
 }

 @Override
 public void run() {
 // 待发送的消息
 OutputStream outputStream = null;
 try {
 outputStream = socket.getOutputStream();
 PrintWriter printWriter = new PrintWriter(outputStream);
 printWriter.write(String.format("我是客户端方[%s],我要我的幸运数字", this.getName()));
 printWriter.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("我是客户端,接收到服务器返回的信息:" + info);
 }
 br.close();
 is.close();
 outputStream.close();
 socket.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }

}