标签：java 一对一 import TCP IOException 聊天 woker new public

客户端代码

import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

	public static void main(String[] args) throws IOException {
		//先建立端口
		Socket socket = new Socket(InetAddress.getLocalHost(),20000);
		//建立工作者
		Woker woker = new Woker(socket);
		//向服务器发送数据的线程
		new Thread(new Sender(woker)).start();
		//接受服务器数据的线程
		new Thread(new Receiver(woker)).start();
	}
}

服务端代码

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

	public static void main(String[] args) throws IOException {
		ServerSocket socket1 = new ServerSocket(20000);
		Socket socket = socket1.accept();
		//工作者
		Woker woker = new Woker(socket);
		//向客户端发送数据线程
		new Thread(new Sender(woker)).start();
		//接受客户端数据线程
		new Thread(new Receiver(woker)).start();
	}

}

工作类（将数据的发送与接收面向对象）

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;

public class Woker {
	Socket socket;
	BufferedReader buf ;
	BufferedWriter buw ;
	BufferedReader in ;
	public Woker(Socket socket) throws IOException {
		this.socket = socket;
		buf = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		buw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
		in = new BufferedReader(new InputStreamReader(System.in));
	}
	public void send() throws IOException {
		 
		while(true) {
			
			buw.write(in.readLine());
			buw.newLine();
			buw.flush();
		}
	}
	public void receive() throws IOException {
		while(true) {
			System.out.println(buf.readLine());
		}
	}
}

发送线程

import java.io.IOException;

public class Sender implements Runnable{
	Woker woker ;
	public Sender(Woker woker) {
		this.woker = woker;
	}
	@Override
	public void run() {
		try {
			woker.send();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

接收线程 

import java.io.IOException;

public class Receiver implements Runnable{
	Woker woker ;
	public Receiver(Woker woker) {
		this.woker = woker;
	}
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			woker.receive();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
}

标签：java,一对一,import,TCP,IOException,聊天,woker,new,public
来源： https://blog.csdn.net/luoyunfan6/article/details/98650156

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。