javaTCP协议实现一对一聊天

?我们首先要完成服务端，不然出错，运行也要先运行服务端，如果不先连接服务端，就不监听，那客户端不知道连接谁

服务端

package d21z;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
 
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
 
public class fwd extends JFrame implements ActionListener,KeyListener {
	//1.窗体组件
	
	//文本域
	 private JTextArea wby;
	 //滚动条
	 private JScrollPane gdt;
	 //输入面板
	 private JPanel mb;
	 //文本框
	private JTextField wbk;
	//按钮
	private JButton an ;
	//输出流
	private BufferedWriter BW=null;
	
	public fwd() {
		
		//将组件初始化
		wby=new JTextArea();
		//设置文本域不可编辑
		wby.setEditable(false);
		//要将文本域放到滚动条中，实现滚动效果
		gdt=new JScrollPane(wby);
		//面板
		mb=new JPanel();
		wbk=new JTextField(10);
		an=new JButton("发送");
		//文本框和按钮要放到面板中
		mb.add(wbk);
		mb.add(an);
		//将滚动条和面板放到窗体中
		this.add(gdt,BorderLayout.CENTER);//将文本内容也就是滚动条放到窗体的中间
		this.add(mb,BorderLayout.SOUTH);//将输入面板放到窗体的底（南）部
		
		//窗体属性
		setTitle("服务端");//标题
		setSize(400,400);//窗体大小
		setLocation(250,200);//位置
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//关闭方式
		setVisible(true);//是否显示
		
		//发送事件
		
		an.addActionListener(this);
		wbk.addKeyListener(this);
		
		try {
			//创建套接字
			ServerSocket s=new ServerSocket(8998);
			Socket sk = s.accept();
			
			
				//获取输入流(读取文本框的数据)
				//使用BufferedReader的readLine()方法，为了一行一行读取
				
				BufferedReader r=new BufferedReader(new InputStreamReader(sk.getInputStream()));
				//获取输出流（输出数据）也是一行一行的
				//BufferedWriter的newLine()方法
				 BW=new BufferedWriter(new OutputStreamWriter(sk.getOutputStream()));
				
				//循环获取数据，并拼接到文本域中
				String line=null;
				while((line=r.readLine())!=null) {
					//将读取的数据拼接到文本域中
					wby.append(line+"\n");
				}
				
				//关闭
				s.close();
				sk.close();
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	public void sx() {
		//获取文本框的数据
				String text=wbk.getText();
				//拼接要发送的内容
				text="服务端："+text;
				//服务端面板显示
				wby.append(text+"\n");
				
				try {
					//发送
					BW.write(text);
					//换行
					BW.newLine();
					
					//刷新
					BW.flush();
					//让文本框为空
					wbk.setText("");
					
				
				}catch(IOException e1) {
					e1.printStackTrace();
				}
	}
	public static void main(String[] args) {
		new fwd();
 
	}
	@Override//按钮事件
	public void actionPerformed(ActionEvent e) {
		sx();
	}
	//回车事件
@Override
	public void keyPressed(KeyEvent e) {
		if(e.getKeyCode()==KeyEvent.VK_ENTER) {
			sx();
		}
		
	}
	@Override
	public void keyTyped(KeyEvent e) {
		// TODO Auto-generated method stub
		
	}
	@Override
	public void keyReleased(KeyEvent e) {
		// TODO Auto-generated method stub
		
	}
 
}

?客户端

package d21z;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
 
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
 
public class Khd extends JFrame implements ActionListener,KeyListener{
	//1.窗体组件
	
		//文本域
		 private JTextArea wby;
		 //滚动条
		 private JScrollPane gdt;
		 //输入面板
		 private JPanel mb;
		 //文本框
		private JTextField wbk;
		//按钮
		private JButton an ;
		
		private BufferedWriter BW=null;
		public Khd() {
			
			//将组件初始化
			wby=new JTextArea();
			//设置文本域不可编辑
			wby.setEditable(false);
			//要将文本域放到滚动条中，实现滚动效果
			gdt=new JScrollPane(wby);
			//面板
			mb=new JPanel();
			wbk=new JTextField(10);
			an=new JButton("按钮");
			//文本框和按钮要放到面板中
			mb.add(wbk);
			mb.add(an);
			//将滚动条和面板放到窗体中
			this.add(gdt,BorderLayout.CENTER);//将文本内容也就是滚动条放到窗体的中间
			this.add(mb,BorderLayout.SOUTH);//将输入面板放到窗体的底（南）部
			
			//窗体属性
			setTitle("客户端");//标题
			setSize(400,400);//窗体大小
			setLocation(800,200);//位置
			setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//关闭方式
			setVisible(true);//是否显示
			
			
			//绑定一个发送的监听事件
			
			an.addActionListener(this);
			wbk.addKeyListener(this);
			try {
			//创建客户端的套接字（尝试连接）
			Socket sk=new Socket("127.0.0.1",8998);
			//获取Socket的输入流
			BufferedReader r=new BufferedReader(new InputStreamReader(sk.getInputStream()));
			//获取Socket的输出流
			 BW=new BufferedWriter(new OutputStreamWriter(sk.getOutputStream()));
 
			//循环获取数据，并拼接到文本域中
			String line=null;
			while((line=r.readLine())!=null) {
				//循环读取
				wby.append(line+"\n");
			}
			
			//关闭Socket通道
			sk.close();
			
			}catch(IOException e) {
				e.printStackTrace();
				
				};
			
		}
		public void sx() {
			//获取文本框的数据
			String text=wbk.getText();
			//拼接要发送的内容
			text="客户端："+text;
			//服务端面板显示
			wby.append(text+"\n");
			
			try {
				//发送
				BW.write(text);
				//换行
				BW.newLine();
				//刷新
				BW.flush();
				//让文本框为空
				wbk.setText("");
			
			}catch(IOException e1) {
				e1.printStackTrace();
			}
		
		}
		public static void main(String[]args) {
			new Khd();
		}
		@Override
		public void actionPerformed(ActionEvent e) {
			sx();
			
		}
		@Override
		public void keyPressed(KeyEvent e) {
			if(e.getKeyCode()==KeyEvent.VK_ENTER) {
			sx();
			}
			}
		@Override
		public void keyTyped(KeyEvent e) {
			// TODO Auto-generated method stub
			
		}
		
		@Override
		public void keyReleased(KeyEvent e) {
			// TODO Auto-generated method stub
			
		}
		
}

运行结果：