package server_1;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
 
 
public class MyTcp {
 
	private ServerSocket server;	//設置服務器套接字
	private Socket client;		//設置客戶端套接字
	
	//連接客戶端函數(shù)
	void getServer()
	{
		try {
			server = new ServerSocket(1100);	//建立服務器 端口為1100
			System.out.println("服務器建立成功！正在等待連接......");
			client = server.accept();	//調(diào)用服務器函數(shù)對客戶端進行連接			
			System.out.println("客戶端連接成功！ip為：" + client.getInetAddress());	//返回客戶端IP		
			getClientMessage();		//調(diào)用信息傳輸和接收函數(shù)
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	void getClientMessage()
	{
		try {
			while (true) {
				InputStream is = client.getInputStream();	//獲取到客戶端的輸入流
				byte[] b = new byte[1024];	//定義字節(jié)數(shù)組
				int len = is.read(b);	//由于信息的傳輸是以二進制的形式，所以要以二進制的形式進行數(shù)據(jù)的讀取
				String data = new String(b, 0,len);
				System.out.println("客戶端發(fā)來消息：" + data);
				
				//定義發(fā)送給客戶端的輸出流
				OutputStream put = client.getOutputStream();
				String putText = "我已經(jīng)收到！歡迎你！";
				put.write(putText.getBytes());	//將輸出流信息以二進制的形式進行寫入
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
		try {
			//判斷客戶端字節(jié)流不是空，則關閉客戶端
			if (server != null) {
				server.close();
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		MyTcp myTcp = new MyTcp();	//調(diào)用該類生成對象
		myTcp.getServer();	//調(diào)用方法
	}
 
}

package client_1;
 
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class MyClient {
	private Socket client;	//定義客戶端套接字
	
	//建立客戶端函數(shù)
	void getClient()
	{
		try {
			client = new Socket("127.0.0.1", 1100);	//建立客戶端，使用的IP為127.0.0.1，端口和服務器一樣為1100
			System.out.println("客戶端建立成功！");
			
			setClientMessage();		//調(diào)用客戶端信息寫入函數(shù)
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	//定義客戶端信息寫入函數(shù)
	void setClientMessage()
	{
		try {		
			OutputStream pt = client.getOutputStream();		//建立客戶端信息輸出流
			String printText = "服務器你好！我是客戶端！";	
			pt.write(printText.getBytes());		//以二進制的形式將信息進行輸出
			
			InputStream input = client.getInputStream();	//建立客戶端信息輸入流
			byte [] b = new byte[1024];		//定義字節(jié)數(shù)組
			int len = input.read(b);	//讀取接收的二進制信息流
			String data = new String(b, 0,len);
			System.out.println("收到服務器消息：" + data);
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
 
		try {
			//如果客戶端信息流不為空，則說明客戶端已經(jīng)建立連接，關閉客戶端
			if (client != null) {
				client.close();
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		//生成客戶端類對象
		MyClient myClient = new MyClient();
		myClient.getClient();
	}
 
}