client.java

java点对点客户端和服务器端

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

import javax.swing.*;
import com.kettas.common.*;

public class Client {
	JFrame f;
	JTextArea jta;
	JTextField jtf;
	JComboBox jcb;
	JScrollPane jsp;
	JPanel jp;
	Socket s;
	BufferedReader in;
	String name;
	public void gui() {
		System.out.println("请输入您的名字：");
		name = SystemIn.readString();
		f = new JFrame(name);
		f.setSize(400, 300);
		jta = new JTextArea();
		jsp = new JScrollPane(jta);
		jtf = new JTextField(30);
		jcb = new JComboBox();
		jcb.addItem("all");
		jp = new JPanel();
		jp.add(jcb);
		jp.add(jtf);
		f.add(jp, "South");
		f.add(jsp);
		f.setVisible(true);
		f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		jta.setEditable(false);

		try {
			s = new Socket("127.0.0.1", 3308);
			in = new BufferedReader(new InputStreamReader(s
					.getInputStream()));
			final PrintWriter pw = new PrintWriter(s.getOutputStream());
			String s=in.readLine();//读取有多少人在线，目的是通知目前客户现在有哪些人在线
			
			String[] ss=s.split(":");
		//	System.out.println("&&&&&&&&&&&&&&&&&&"+ss.length);
			for(int i=1;i<ss.length;i++){//从这可以得到目前有多少人在线，通知新上线的
				
				jcb.addItem(ss[i]);
				//System.out.print(sss+"****************");
				jta.append(ss[i]+"上线了\n");
				}
			
			
			pw.println(name);//发送给服务器目前登陆的客户名字，目的是让服务器能够通知其他客户
			pw.flush();
			
			jtf.addActionListener(new ActionListener() {//监听器设置
				public void actionPerformed(ActionEvent arg0) {
					String text = jtf.getText();
					if (!jcb.getSelectedItem().equals("all")){//点对点
						pw.println("1:" + jcb.getSelectedItem() + ":" + text);
						pw.flush();}
					else if(jcb.getSelectedItem().equals("all")){//群发
						pw.println("2:" + text);
						pw.flush();}
					jtf.setText("");
				}
			});
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void receive() {//收信息的协议，1为上线，2为下线，其他为正常
		try {
			
			while (true) {
				String s = in.readLine();
				if (s == null){
					return;
					}
				String ss[]=s.split(":");
				
				if(ss[0].equals("1")){
					jcb.addItem(ss[1]);
					jta.append(ss[1]+"上线了\n");
				}else if(ss[0].equals("2")){
					jcb.removeItem(ss[1]);
					jta.append(ss[1]+"下线了\n");
				}
				else
				jta.append(s + "\n");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public static void main(String args[]){
		Client c=new Client();
		c.gui();
		c.receive();
	}
}