TestTCPServer
package socketdemo;

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

public class TestTCPServer {
	public static void main(String[] args) throws IOException {
		ServerSocket ss = new ServerSocket(9999);
		while(true){
			System.out.println("----------服务端已经启动------------");
			Socket s = ss.accept();
//			System.out.println(s.getLocalPort()+"  "+s.getPort()+"  "+s.getLocalAddress().getHostAddress());
//			System.out.println(s.getInetAddress().getHostAddress()+":"+s.getPort()+
//					"客户端已经 连接上服务器ServerSocket");
			DataOutputStream dos = new DataOutputStream(s.getOutputStream());
			System.out.println("客户端【"+s.getInetAddress().getHostAddress()+"::"+s.getPort()+"】已经连接");
			dos.writeUTF("服务器端写入客户端的数据：客户端【"+s.getInetAddress().getHostAddress()+"::"+s.getPort()+
					"】已经连接上服务器端【"+s.getLocalAddress().getHostAddress()+"::"+s.getLocalPort()+"】！");
			dos.flush();
			dos.close();
			s.close();
		}
	}

}

TestTCPClient
package socketdemo;

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

public class TestTCPClient {
	public static void main(String[] args)throws IOException {
		for(int i =0;i<5;i++){
			Socket s = new Socket("192.168.0.2",9999);
//			------------------------------------------
			DataInputStream dis = new DataInputStream(s.getInputStream());
			System.out.println("接收："+dis.readUTF());
			dis.close();
//			------------------------------------------
			s.close();
		}
	}
}

ServerSocket01
package socket;

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

public class ServerSocket01 {
	public static void main(String[] args) {
		ServerSocket server = null;
		try{
//			服务器在9999端口开辟了服务
			server = new ServerSocket(9999);
		}catch(Exception e){}
//		对于服务器而言，所有用户的请求都是通过ServerSocket实现
		Socket client = null;
		try{
//			服务器在此等待用户的链接
			System.out.println("等待客户端连接...");
			client = server.accept();//服务端受到的一个client
		}catch(Exception e){}
//		要向客户端打印信息
		PrintStream out = null;
//		得到向客户端输出信息的能力
		try{
			out = new PrintStream(client.getOutputStream());
		}catch(Exception e){}
		out.println("How are you ?");
		try{
			client.close();
			server.close();
		}catch(Exception e){}
		System.out.println("客户端回应完毕...");

	}

}

ClientSocket01
package socket;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

public class ClientSocket01 {
	public static void main(String[] args) {
		Socket client=null;
		try {
//			实际上表示要链接到服务器上去了
			client=new Socket("192.168.0.2",9999);
			//192.168.0.2是本人的局域网IP地址
		} catch (Exception e) {} 
//		等待服务器的回应
		String str = null;
//		如果直接使用InputStream接收会比较麻烦
		BufferedReader buf = null;
		try{
			buf = new BufferedReader(new InputStreamReader(client.getInputStream()));
			str = buf.readLine();
		}catch(Exception e){}
		System.out.println(str);
	}

}

Demo01
package demo;
class Shoes{
//	鞋子类，两个属性：使用者（男/女），大小（大/小）
	String user=null;
	String size=null;
}
class Pro implements Runnable{
//	生产者，生产
	Shoes shoe = null;
	public Pro(Shoes s){
		this.shoe=s;
	}
	public void run(){
		int i=0;
		while(true){
			if(i==0){
//				男人穿的鞋子是大号的
				shoe.user="男式";
				shoe.size="大号";
				i=1;
			}else{
//				女人穿的鞋子是小号的
				shoe.user="女式";
				shoe.size="小号";
				i=0;
			}
		}
	}
}
class Cus implements Runnable{
	Shoes shoe=null;
	public Cus(Shoes s){
		this.shoe=s;
	}
	public void run(){
		while(true){
			System.out.println(shoe.user+"-->"+shoe.size);
		}
	}
}
public class Demo01 {

	/**生产者-消费者问题  producer-consumer
	 * @param args
	 */
	public static void main(String[] args) {
//		设置鞋子的一个生产者和一个消费者，并启动两个线程，分别进行生产和消费
		Shoes shoe = new Shoes();
		Pro p = new Pro(shoe);
		Cus c = new Cus(shoe);
		new Thread(p).start();
		new Thread(c).start();
	}

}

Demo02
package demo2;

class Shoes{
//	鞋子类，两个属性：使用者（男/女），大小（大/小）
	String user=null;
	String size=null;
	private boolean flag = true;
	public synchronized void set(String user,String size){    
        //如果flag的值不是true则要等待    
        if (!flag){    
                //等待    
                try{    
                        wait();    
                }catch(Exception e){}    
        }    
        try{    
                Thread.sleep(100);    
        }catch (Exception e){}    
        // 如果向下继续执行了，则表示可以设置,flag = true    
        this.user = user;    
        this.size = size;    
        // 修改设置的标志    
        flag = false;    
        //唤醒其他线程    
        notify();    
}    
//设置一个输出方法    
public synchronized void get(){    
    // 如果flag的值为true的时候，表示要等待    
    if(flag){    
            try{    
                    wait();    
            }catch(Exception e){}    
    }    
    try{    
            Thread.sleep(100);    
    }catch (Exception e){}    
    //如果向下执行了，则表示允许取出    
    System.out.println(this.user+" --> "+this.size);    
    //改变标志，表示可以生产了    
    flag = true;    
    notify();    
}
}
class Pro implements Runnable{
//	生产者，生产
	Shoes shoe = null;
	public Pro(Shoes s){
		this.shoe=s;
	}
	public void run(){
		int i=0;
		while(true){
			if(i==0){
//				男人穿的鞋子是大号的
				shoe.set("男式", "大号");
				i=1;
			}else{
//				女人穿的鞋子是小号的
				shoe.set("女式", "小号");
				i=0;
			}
		}
	}
}
class Cus implements Runnable{
	Shoes shoe=null;
	 public Cus(Shoes s){    
         this.shoe = s;    
 }    
 public void run(){    
         while(true){    
                 shoe.get();    
         }    
 }   
}
public class Demo02 {

	/**生产者-消费者问题  producer-consumer
	 * @param args
	 */
	public static void main(String[] args) {
//		设置鞋子的一个生产者和一个消费者，并启动两个线程，分别进行生产和消费
		Shoes shoe = new Shoes();
		Pro p = new Pro(shoe);
		Cus c = new Cus(shoe);
		new Thread(p).start();
		new Thread(c).start();
	}

}

Waiter
package queuebanknew;

public class Waiter {
	private int num;
	private int frontNum;
	private int flag;
	public int getFlag() {
		return flag;
	}
	public void setFlag(int flag) {
		this.flag = flag;
	}
	public int getNum() {
		return num;
	}
	public void setNum(int num) {
		this.num = num;
	}
	public int getFrontNum() {
		return frontNum;
	}
	public void setFrontNum(int frontNum) {
		this.frontNum = frontNum;
	}
	

}

Counter
package queuebanknew;

public class Counter {
	private int id;
	private String name;
	private Waiter w;
	public Counter(Waiter waiter) {
		this.w=waiter;
	}
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public Waiter getW() {
		return w;
	}
	public void setW(Waiter w) {
		this.w = w;
	}
	public void handBussines(){
		System.out.println("正在处理："+this.w.getNum()+"号");
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("处理完毕："+this.getW().getNum());
	}

}

TestBankQueue
package queuebanknew;

import java.util.Queue;

public class TestBankQueue {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		
		
		QueueServer qs = new QueueServer();
		Queue<Waiter> waiterList = qs.init();//初始化10个等待者
		Waiter waiter= null;
		while(true){//模拟工作人员处理业务
			waiter = waiterList.poll();
			if(waiter != null){
				Counter counter = new Counter(waiter);
				counter.handBussines();
			}else{
				break;
			}
		}
	}
}

QueueServer
package queuebanknew;

import java.util.LinkedList;


public class QueueServer {
	LinkedList<Waiter> waiterList = new LinkedList<Waiter>();
	
	public LinkedList<Waiter> init(){
		for(int i=1;i<=10;i++){
			Waiter w = new Waiter();
		    w.setNum(i);
		    w.setFrontNum(i-1);
		    waiterList.offer(w);
		}
		return waiterList;
		
	}

}

BankWorkerUI
package queuebanknew;

import java.util.Queue;

import org.eclipse.swt.SWT;
import org.eclipse.swt.events.SelectionAdapter;
import org.eclipse.swt.events.SelectionEvent;
import org.eclipse.swt.widgets.Button;
import org.eclipse.swt.widgets.Display;
import org.eclipse.swt.widgets.Shell;
import org.eclipse.swt.widgets.Text;

public class BankWorkerUI {
	public static void main(String[] args) {
		final Display display = Display.getDefault();
		final Shell shell = new Shell();
		shell.setSize(327, 253);
		shell.setText("银行排队---工作人员客户端");
//		新插入的界面核心代码
		QueueServer qs = new QueueServer();
		final Queue<Waiter> waiterList = qs.init();
		
		final Text txt = new Text(shell,SWT.MULTI);
		txt.setBounds(65,30,180,70);
//		事件代码里要访问button
		final Button button = new Button(shell,SWT.Activate);
		button.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Waiter waiter = waiterList.poll();
				if(waiter!=null){
					txt.setText(waiter.getNum()+"号顾客到1号窗口办理");
				}else{
					txt.setText("没人办理业务");
				}
			}
		});
		button.setBounds(90, 141, 100, 25);
		button.setText("下一个");
		shell.layout();
		shell.open();
		while(!shell.isDisposed()){
			if(!display.readAndDispatch())
				display.sleep();
			
		}
	}

}

WaiterQueueUI
package queuebanknew;

import java.util.LinkedList;

import org.eclipse.swt.SWT;
import org.eclipse.swt.events.SelectionAdapter;
import org.eclipse.swt.events.SelectionEvent;
import org.eclipse.swt.graphics.Font;
import org.eclipse.swt.widgets.Button;
import org.eclipse.swt.widgets.Display;
import org.eclipse.swt.widgets.Shell;
import org.eclipse.swt.widgets.Text;

public class WaiterQueueUI {
	public static void main(String[] args){
		final Display display = Display.getDefault();
		final Shell shell = new Shell();
		shell.setBounds(100, 100, 570, 380);
//		shell.setMaximized(true);
		shell.setText("银行排队----顾客客户端");
//		界面核心代码
		QueueServer qs = new QueueServer();
		final LinkedList<Waiter> waiterList = qs.init();
		final Text txt = new Text(shell,SWT.MULTI);
		
		txt.setBounds(50,50,200,150);
//		事件代码里要访问button，所以要添加final
		final Button button = new Button(shell,SWT.Activate);
		button.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Waiter waiter = new Waiter();
				waiter.setNum(waiterList.size()+1);
				waiter.setFrontNum(waiterList.size());
				waiterList.offer(waiter);
				
				if(waiterList.size()<=20){
					txt.setText("您现在排在"+waiter.getNum()+"位置上\n您前面有"+waiter.getFrontNum()+"个人，请耐心等待！！");
				}else{
					txt.setText("您前面已经排20多人，请考虑！\n"+"您现在排在"+waiter.getNum()+"位置上，\n您前面有"+waiter.getFrontNum()+"个人，请耐心等待！！");
				}
			}
			
		});
		button.setBounds(75, 250, 150, 50); // 设置按钮位置
		button.setFont(new Font(display,"宋体",12,SWT.BOLD));
		button.setText("个人业务");// 设置按钮上的文字
//		------------------------------------------------------------------------
		final Text goldTxt = new Text(shell,SWT.NULL);
		goldTxt.setBounds(300,50,200,150);
//		事件代码里要访问button，所以要添加final
		final Button goldButton = new Button(shell,SWT.Activate);
		goldButton.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Waiter w = new Waiter();
				w.setFlag(1);
				waiterList.addFirst(w);
				
				goldTxt.setText("金卡用户，下一位就是您！");
			}
			
		});
		goldButton.setBounds(325, 250, 150, 50); // 设置按钮位置
		goldButton.setFont(new Font(display,"宋体",12,SWT.BOLD));
		goldButton.setText("金卡通道");// 设置按钮上的文字
		// ------------------END---------------------------------------------
		shell.layout();
		shell.open();
		while (!shell.isDisposed()) {
			if (!display.readAndDispatch())
				display.sleep();
		}
	}
}

Patient
package hospital;

public class Patient {
	private String name;
	private int flag;
	private int num;
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getFlag() {
		return flag;
	}
	public void setFlag(int flag) {
		this.flag = flag;
	}
	public void setNum(int num) {
		this.num = num;
	}
	public int getNum() {
		return num;
	}
	
}

Doctor
package hospital;

public class Doctor {
	private int id;
	private String name;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	

}

QueueServer
package hospital;

import java.util.LinkedList;
import java.util.Queue;


public class QueueServer {
	Queue<Patient> patientList1 = new LinkedList<Patient>();
	Queue<Patient> patientList2 = new LinkedList<Patient>();
	Queue<Patient> patientList3 = new LinkedList<Patient>();
	
	public Queue<Patient> init1(){
		for(int i=1;i<=10;i++){
			Patient p = new Patient();
		    p.setNum(i);
			patientList1.offer(p);
		}
		return patientList1;
	}
	public Queue<Patient> init2(){
		for(int i=1;i<=15;i++){
			Patient p = new Patient();
		    p.setNum(i);
			patientList2.offer(p);
		}
		return patientList2;
	}
	public Queue<Patient> init3(){
		for(int i=1;i<=20;i++){
			Patient p = new Patient();
		    p.setNum(i);
			patientList3.offer(p);
		}
		return patientList3;
	}

}

PatientUI
package hospital;

import java.util.Queue;

import org.eclipse.swt.SWT;
import org.eclipse.swt.events.SelectionAdapter;
import org.eclipse.swt.events.SelectionEvent;
import org.eclipse.swt.graphics.Font;
import org.eclipse.swt.widgets.Button;
import org.eclipse.swt.widgets.Display;
import org.eclipse.swt.widgets.Shell;
import org.eclipse.swt.widgets.Text;

public class PatientUI {
	public static void main(String[] args){
		final Display display = Display.getDefault();
		final Shell shell = new Shell();
		shell.setBounds(100, 100, 620, 450);
//		shell.setMaximized(true);
		shell.setText("医院专家挂号系统");
//		界面核心代码
		QueueServer qs1 = new QueueServer();
		final Queue<Patient> patientList1 = qs1.init1();
		final Text txt = new Text(shell,SWT.MULTI);
		txt.setFont(new Font(display,"宋体",20,SWT.BOLD));
		txt.setBounds(100,50,400,200);
//		事件代码里要访问button，所以要添加final
		final Button button = new Button(shell,SWT.Activate);
		button.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Patient patient = new Patient();
				patient.setNum(patientList1.size()+1);
				patientList1.offer(patient);
				if(patientList1.size()<=20){
					txt.setText("\n您选择了  张医生\n\n您现在排在"+patient.getNum()+"号位置上");
				}else{
					txt.setText("\n您选择了  张医生\n\n您现在排在"+patient.getNum()+"号位置上\n\n前面已经排20多人，请考虑！");
				}
			}
		});
		button.setBounds(50, 300, 150, 55); // 设置按钮位置
		button.setFont(new Font(display,"宋体",12,SWT.BOLD));
		button.setText("专家 张医生");// 设置按钮上的文字
		// -----------------2号专家||||--------------------------------------------
		QueueServer qs2 = new QueueServer();
		final Queue<Patient> patientList2 = qs2.init2();
		final Button button2 = new Button(shell,SWT.Activate);
		button2.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Patient patient = new Patient();
				patient.setNum(patientList2.size()+1);
				patientList2.offer(patient);
				if(patientList2.size()<=20){
					txt.setText("\n您选择了  王医生\n\n您现在排在"+patient.getNum()+"号位置上");
				}else{
					txt.setText("\n您选择了  王医生\n\n您现在排在"+patient.getNum()+"号位置上\n\n前面已经排20多人，请考虑！");
				}
			}
		});
		button2.setBounds(225, 300, 150, 55); // 设置按钮位置
		button2.setFont(new Font(display,"宋体",12,SWT.BOLD));
		button2.setText("专家 王医生");// 设置按钮上的文字
//		--------------------3号专家||||------------------------------------
		QueueServer qs3 = new QueueServer();
		final Queue<Patient> patientList3 = qs3.init3();
		final Button button3 = new Button(shell,SWT.Activate);
		button3.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Patient patient = new Patient();
				patient.setNum(patientList3.size()+1);
				patientList3.offer(patient);
				if(patientList3.size()<=20){
					txt.setText("\n您选择了  李医生\n您现在排在"+patient.getNum()+"号位置上");
				}else{
					txt.setText("\n您选择了  李医生\n\n您现在排在"+patient.getNum()+"号位置上\n\n前面已经排20多人，请考虑！");
				}
			}
		});
		button3.setBounds(400, 300, 150, 55); // 设置按钮位置
		button3.setFont(new Font(display,"宋体",12,SWT.BOLD));
		button3.setText("专家 李医生");// 设置按钮上的文字
//		-----------------------END---------------------------------------
		shell.layout();
		shell.open();
		while (!shell.isDisposed()) {
			if (!display.readAndDispatch())
				display.sleep();
		}
	}
}

DoctorUI
package hospital;

import java.util.Queue;
import org.eclipse.swt.SWT;
import org.eclipse.swt.events.SelectionAdapter;
import org.eclipse.swt.events.SelectionEvent;
import org.eclipse.swt.graphics.Font;
import org.eclipse.swt.widgets.Button;
import org.eclipse.swt.widgets.Display;
import org.eclipse.swt.widgets.Shell;
import org.eclipse.swt.widgets.Text;

public class DoctorUI {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		final Display display = Display.getDefault();
		final Shell shell = new Shell();
		shell.setBounds(200, 100, 420, 350);
		shell.setText("医院专家挂号系统--张医生客户端");
//		界面核心代码
		QueueServer qs1 = new QueueServer();
		final Queue<Patient> patientListz = qs1.init1();
        final Text txt = new Text(shell,SWT.MULTI);
		txt.setFont(new Font(display,"微软雅黑",13,SWT.BOLD));
		txt.setBounds(50,50,300,100);
//		事件代码里要访问button，所以要添加final
		final Button button = new Button(shell,SWT.Activate);
		button.addSelectionListener(new SelectionAdapter(){
			public void widgetSelected(SelectionEvent e){
				Patient p = patientListz.poll();
				if(p!=null){
					txt.setText("\n\t\t第   "+p.getNum()+"  号病人" +
							"\n\t 请到张医生医务室就医");
				}
				else{
					txt.setText("\n\t现在没有病人看病了");
				}
			}
		});
		button.setBounds(100, 200, 200, 75); // 设置按钮位置
		button.setFont(new Font(display,"微软雅黑",14,SWT.BOLD));
		button.setText("下一位..");// 设置按钮上的文字
//		---------------------END----------------------------
		shell.layout();
		shell.open();
		while (!shell.isDisposed()) {
			if (!display.readAndDispatch())
				display.sleep();
		}

	}

}

Course
import java.util.ArrayList;
import java.util.List;

public class Course {
	private String name;
	private float grade;
	private List<Student> allStudents;
	
	public Course(String name,float grade){
		this.setAllStudents(new ArrayList<Student>());
		this.setGrade(grade);
		this.setName(name);
	}
	public void addStu(Student student){
		this.allStudents.add(student);
	}
	
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public float getGrade() {
		return grade;
	}
	public void setGrade(float grade) {
		this.grade = grade;
	}
	public List<Student> getAllStudents() {
		return allStudents;
	}
	public void setAllStudents(List<Student> allStudents) {
		this.allStudents = allStudents;
	}
}

Student
import java.util.ArrayList;
import java.util.List;

public class Student {
	private String name;
	private int age;
	private List<Course> allCourse;//一个学生可以选多门课
	
	public Student(String name,int age){
		this.setAge(age);
		this.setAllCourse(new ArrayList<Course>());
		this.setName(name);
	}
	public void addCourse(Course course){
		this.allCourse.add(course);
	}
	
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}
	public List<Course> getAllCourse() {
		return allCourse;
	}
	public void setAllCourse(List<Course> allCourse) {
		this.allCourse = allCourse;
	}
}

TestCourse
import java.util.Iterator;

public class TestCourse {
	public static void main(String[] args) {
		Student stu1 = new Student("张三",20);
		Student stu2 = new Student("李四",21);
		Student stu3 = new Student("王五",22);
		Student stu4 = new Student("赵柳",23);
		Student stu5 = new Student("孙琦",24);
		Course c1 = new Course("Java se 基础",2.0f);
		Course c2 = new Course("Java se web",3.0f);
		Course c3 = new Course("分布式开发",5.0f);
//		设置关系
		stu1.addCourse(c1);
		c1.addStu(stu1);
		stu1.addCourse(c2);
		c2.addStu(stu1);
		
		stu2.addCourse(c2);
		c2.addStu(stu2);
		
		stu3.addCourse(c1);
		c1.addStu(stu3);
		stu3.addCourse(c2);
		c2.addStu(stu3);
		stu3.addCourse(c3);
		c3.addStu(stu3);
		
		stu4.addCourse(c3);
		c3.addStu(stu4);
		
		stu5.addCourse(c3);
		c3.addStu(stu5);
		
		System.out.println("学生姓名："+stu1.getName());
		Iterator<Course> it1 = stu1.getAllCourse().iterator();
		while(it1.hasNext()){
			Course c = it1.next();
			System.out.println("\t|-课程名称："+c.getName()+",学分："+c.getGrade());
		}
		
		System.out.println("课程名称："+c3.getName());
		Iterator<Student> it2 = c3.getAllStudents().iterator();
		while(it2.hasNext()){
			Student s = it2.next();
			System.out.println("\t|-学生姓名："+s.getName()+",年龄："+s.getAge());
		}
	}

}

Message
public class Message {
	private String from;
	private String to;
	private String content;
	public String getFrom() {
		return from;
	}
	public void setFrom(String from) {
		this.from = from;
	}
	public String getTo() {
		return to;
	}
	public void setTo(String to) {
		this.to = to;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	
}

QQInterface
public interface QQInterface {
	void sendMsg(Message msg);
	Message receiveMsg(String name);

}

QQServer
import java.util.HashMap;
import java.util.Map;

public class QQServer {
	static Map<String,Message> serverMap = new HashMap<String,Message>();
	public static void serverReceiveMsg(Message msg){
		serverMap.put(msg.getTo(),msg);
		System.out.println(msg.getFrom()+" "+" "+msg.getContent());
	}
	public static Message asked(String name){
		Message msg = serverMap.get(name);
		return msg;
	}
}

QQ1
public class QQ1 implements QQInterface{
	public static void main(String[] args){
		Message msg = new Message();
		msg.setFrom("QQ1");
		msg.setTo("QQ2");
		msg.setContent("I am QQ1 。");
		QQ1 q = new QQ1();
		q.sendMsg(msg);
	}
	public void sendMsg(Message msg){
		QQServer.serverReceiveMsg(msg);
	}
	@Override
	public Message receiveMsg(String name) {
		Message msg = QQServer.asked(name);
		System.out.println("******"+msg.getContent());
		return msg;
	}

}

QQ2
public class QQ2 implements QQInterface{
	public static void main(String[] args){
		Message msg = new Message();
		msg.setFrom("QQ2");
		msg.setTo("QQ1");
		msg.setContent("I am QQ2 。");
		QQ2 q = new QQ2();
		q.sendMsg(msg);
	}
	public void sendMsg(Message msg){
		QQServer.serverReceiveMsg(msg);
	}
	@Override
	public Message receiveMsg(String name) {
		Message msg = QQServer.asked(name);
		System.out.println("******"+msg.getContent());
		return msg;
	}
}

Test
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class Test {
	public static void main(String[] args){
		Map<String,List<Message>> QQMap = new HashMap<String,List<Message>>();
		List<Message> msgList = new ArrayList<Message>();
		
//		第一次发送消息
		Message msg1 = new Message();
		msg1.setFrom("QQ1");
		msg1.setTo("QQ2");
		msg1.setContent("HI!");
		msgList.add(msg1);
		QQMap.put(msg1.getTo(), msgList);
//		第二次发送消息
		Message msg2 = new Message();
		msg2.setFrom("QQ1");
		msg2.setTo("QQ2");
		msg2.setContent("Hello World !");
		msgList.add(msg2);
		QQMap.put(msg2.getTo(), msgList);
		
        List<Message> qq2MsgList = QQMap.get("QQ2");
		for(Message m:qq2MsgList){//打印QQ1发给QQ2消息
			System.out.println(m.getContent());
		}
	}
}