实现的简单的多个客户端聊天程序代码,Java代码库,德仔网

代码语言
代码分类
【Java】实现的简单的多个客户端聊天程序
作者:亭 / 发布于2014/11/11/ 396

	客户端

	import java.awt.*;
	import java.awt.event.*;
	import java.io.*;
	import java.lang.*;
	import java.net.*;

	public class HeartClient extends Frame {

	 /*
	 * 成员方法出场...
	 */
	 private TextField tfText;
	 private TextArea taContent;
	 private Socket s;
	 private DataOutputStream dos;
	 private DataInputStream dis;

	 /**
	 * 注意，入口... ^^
	 * @param args
	 */
	 public static void main(String[] args) {
	 new HeartClient().launchFrame();

	 }

	 /**
	 * Loading GU
	 */
	 public void launchFrame(){
	 tfText = new TextField();
	 taContent = new TextArea();
	 this.setSize(300,300);
	 this.setLocation(300,300);
	 this.tfText.addActionListener(new TFListener());
	 this.add(tfText,BorderLayout.SOUTH);
	 this.add(taContent,BorderLayout.NORTH);
	 this.addWindowListener(new WindowAdapter(){
	 @Override
	 public void windowClosing(WindowEvent e) {
	 System.exit(0);
	 }});
	 this.pack();
	 this.connect();
	 this.setVisible(true);
	 }

	 /**
	 * 我在努力地连接服务器中...
	 */
	 public void connect() {
	 try {
	 s = new Socket("127.0.0.1",1720);
	 dos = new DataOutputStream(s.getOutputStream());
	 dis = new DataInputStream(s.getInputStream());
	 new Thread(new SendThread()).start();
	// dos.writeUTF("Hello,i find u!");
	 } catch (UnknownHostException e) {
	 System.out.println("UnknownHostException");
	 e.printStackTrace();
	 } catch (IOException e) {
	 System.out.println("IOException");
	 e.printStackTrace();
	 }finally{
	 //关闭啥尼...
	 }

	 }

	 /**
	 * 额不会傻等着tfText(TextField tfText的监听器类)
	 */
	 class TFListener implements ActionListener{
	 private String str;
	 @Override
	 public void actionPerformed(ActionEvent e) {
	 str = tfText.getText().trim();
	 tfText.setText("");
	 try {
	 dos.writeUTF(str);
	 } catch (IOException e1) {
	 System.out.println("IOException");
	 e1.printStackTrace();
	 }
	 }

	 }

	 /**
	 * 客户端接收消息的线程呦...
	 *
	 */
	 class SendThread implements Runnable{
	 private String str;
	 private boolean iConnect = false;

	 public void run(){
	 iConnect = true;
	 recMsg();

	 }

	 /**
	 * 消息，看招，哪里跑...（客户端接收消息的实现）
	 * @throws IOException
	 */
	 public void recMsg() {
	 try {
	 while(iConnect){
	 str = dis.readUTF();
	 taContent.setText(str);
	 }
	 } catch (IOException e) {
	 e.printStackTrace();
	 }

	 }

	 }

	}

	

	

	服务器端

	import java.io.*;
	import java.net.*;
	import java.util.*;

	public class HeartServer {

	 /*
	 * 成员变量闪亮登场
	 */
	 List<ClientThread> clients = new ArrayList<ClientThread>();

	 /**
	 * 这系入口啊，向这里看齐...
	 * @param args
	 */
	 public static void main(String[] args) {
	 new HeartServer().start();
	 }

	 /**
	 * 启动服务器中...
	 *
	 */
	 public void start(){
	 try {
	 boolean iConnect = false;
	 ServerSocket ss = new ServerSocket(1720);
	 iConnect = true;
	 while(iConnect){
	System.out.println("绑定服务器端口成功！");
	 Socket s = ss.accept();
	 ClientThread currentClient = new ClientThread(s);//创建线程引用
	System.out.println("发现客户端！");
	 clients.add(currentClient);//把当前客户端加入集合
	 new Thread(currentClient).start();
	System.out.println("客户端进程已经启动！");
	 }
	 } catch (IOException e) {
	 System.out.println("IOException");
	 e.printStackTrace();
	 }
	 }

	 /**
	 * 给每个客户端留个家（客户端的进程）
	 *
	 */
	 class ClientThread implements Runnable {
	 /*
	 * 成员变量又来啦...
	 */
	 private Socket s;
	 private DataInputStream dis;
	 private DataOutputStream dos;
	 private String str;
	 private boolean iConnect = false;

	 /**
	 * 小构一下
	 */
	 ClientThread(Socket s){
	 this.s = s;
	 iConnect = true;
	 }

	 public void run(){
	System.out.println("run方法启动了！");
	 try {

	 while(iConnect){
	System.out.println("RUN方法中的while循环启动，正在等待客户端的发送消息...");
	 dis = new DataInputStream(s.getInputStream());
	 str = dis.readUTF();
	System.out.println(str);
	 for(int i=0; i<clients.size(); i++){
	System.out.println("转发消息中..."+i);
	 ClientThread c = clients.get(i);
	 c.sendMsg(str);
	 }
	 }
	 } catch (IOException e) {
	 e.printStackTrace();
	 }

	 }

	 /**
	 * 转发消息，我做主...
	 * 将送至服务器的消息发送给每个连接到的客户端
	 */
	 public void sendMsg(String str){
	 try {
	System.out.println("创建输出管道！");
	 dos = new DataOutputStream(this.s.getOutputStream());
	System.out.println("正在向客户端写消息！");
	 dos.writeUTF(str);
	System.out.println("正在向客户端写消息成功！");
	 } catch (IOException e) {
	 e.printStackTrace();
	 }

	 }

	 }

	}
试试其它关键字
　客户端　　聊天程序　
同语言下
可能有用的
亭贡献的其它代码(23)