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;		//设置客户端套接字
	
	//连接客户端函数
	void getServer()
	{
		try {
			server = new ServerSocket(1100);	//建立服务器 端口为1100
			System.out.println("服务器建立成功！正在等待连接......");
			client = server.accept();	//调用服务器函数对客户端进行连接			
			System.out.println("客户端连接成功！ip为：" + client.getInetAddress());	//返回客户端IP		
			getClientMessage();		//调用信息传输和接收函数
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	void getClientMessage()
	{
		try {
			while (true) {
				InputStream is = client.getInputStream();	//获取到客户端的输入流
				byte[] b = new byte[1024];	//定义字节数组
				int len = is.read(b);	//由于信息的传输是以二进制的形式，所以要以二进制的形式进行数据的读取
				String data = new String(b, 0,len);
				System.out.println("客户端发来消息：" + data);
				
				//定义发送给客户端的输出流
				OutputStream put = client.getOutputStream();
				String putText = "我已经收到！欢迎你！";
				put.write(putText.getBytes());	//将输出流信息以二进制的形式进行写入
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
		try {
			//判断客户端字节流不是空，则关闭客户端
			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();	//调用该类生成对象
		myTcp.getServer();	//调用方法
	}

}

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;	//定义客户端套接字
	
	//建立客户端函数
	void getClient()
	{
		try {
			client = new Socket("127.0.0.1", 1100);	//建立客户端，使用的IP为127.0.0.1，端口和服务器一样为1100
			System.out.println("客户端建立成功！");
			
			setClientMessage();		//调用客户端信息写入函数
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	//定义客户端信息写入函数
	void setClientMessage()
	{
		try {		
			OutputStream pt = client.getOutputStream();		//建立客户端信息输出流
			String printText = "服务器你好！我是客户端！";	
			pt.write(printText.getBytes());		//以二进制的形式将信息进行输出
			
			InputStream input = client.getInputStream();	//建立客户端信息输入流
			byte [] b = new byte[1024];		//定义字节数组
			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 {
			//如果客户端信息流不为空，则说明客户端已经建立连接，关闭客户端
			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();
	}

}