java版的QQ小程序

转载自：http://blog.csdn.net/lihongxun945/article/details/6114290

这是一个简单的java版的QQ小程序。

包括一个简单的服务器和一个简单的客户端。

运行时，先运行服务器，然后在运行客户端，就可以进行聊天了。

默认的配置是localhost，端口4545，更改ip就可以在两天电脑上进行聊天了。

目前不支持内网和外网之间的访问，也不支持多人聊天。

因为这只是一个简单的例子，感兴趣的同学可以通过改进，实现多人聊天和内外网之间的访问。

效果图：

下载地址：http://download.csdn.net/source/2958843

源代码：

QQServer.java

[java] view plaincopy

1. //axun @copy right
2. package axun.com;
3. import java.io.BufferedReader;
4. import java.io.DataInputStream;
5. import java.io.DataOutputStream;
6. import java.io.InputStream;
7. import java.io.OutputStream;
8. import java.net.ServerSocket;
9. import java.net.Socket;
10. import java.awt.*;
11. import java.awt.event.*;
12. import javax.swing.*;
13. public class QQServer{
14. private JFrame f=new JFrame("QQ服务器端");
15. private JPanel pleft=new JPanel(new BorderLayout());
16. private JPanel pright=new JPanel();
17. private List list=new List();
18. private TextArea t1=new TextArea();
19. private TextArea t2=new TextArea();
20. private Button b=new Button("发送");
21. //一下是 网络通信用的变量
22. DataOutputStream dos=null;
23. BufferedReader br=null;
24. DataInputStream dis=null;
25. public QQServer(){
26. f.setSize(400,300);
27. f.setLayout(new BorderLayout());
28. f.add(pleft,BorderLayout.WEST);
29. f.add(pright,BorderLayout.CENTER);
30. pleft.add(list);
31. pright.setLayout(new GridLayout(3,1));
32. pright.add(t1);
33. pright.add(t2);
34. pright.add(b);
35. f.setVisible(true);
36. f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
37. b.addActionListener(new bListener());
38. }
39. public void Addt1(String s){
40. t1.append(s);
41. }
42. public void addList(String s){
43. list.addItem(s);
44. }
45. public static void main(String[] args) throws Exception{
46. QQServer server=new QQServer();
47. InputStream in=null;
48. OutputStream out=null;
49. String string=null;
50. ServerSocket ss=new ServerSocket(4545);
51. Socket s=null;
52. s=ss.accept();
53. server.addList(s.toString());
54. in=s.getInputStream();
55. out=s.getOutputStream();
56. server.dis=new DataInputStream(in);
57. server.dos=new DataOutputStream(out);
58. Listen1 l=new Listen1(server,server.dis);
59. Thread t=new Thread(l);
60. t.start();
61. }
62. class bListener implements ActionListener{
63. public void actionPerformed(ActionEvent e) {
64. try{
65. dos.writeUTF(t2.getText());
66. Addt1("发送："+"/n");
67. Addt1("    "+t2.getText()+"/n");
68. t2.setText("");
69. }catch(Exception ep){
70. Addt1("消息发送失败！/n");
71. }
72. }
73. }
74. }
75. class Listen1 implements Runnable{
76. private QQServer server=null;
77. private DataInputStream dis=null;
78. private String s=null;
79. Listen1(QQServer server,DataInputStream dis){
80. this.server=server;
81. this.dis=dis;
82. }
83. public void run() {
84. // TODO Auto-generated method stub
85. try{
86. while(true){
87. s=dis.readUTF();
88. server.Addt1("收到："+"/n");
89. server.Addt1("    "+s+"/n");
90. }
91. }catch(Exception e){
92. server.Addt1("Error!："+s+"/n");
93. }
94. }
95. }

QQClient.java

[java] view plaincopy

1. //axun @copy right
2. package axun.com;
3. import java.io.BufferedReader;
4. import java.io.DataInputStream;
5. import java.io.DataOutputStream;
6. import java.io.InputStream;
7. import java.io.OutputStream;
8. import java.net.Socket;
9. import java.awt.*;
10. import javax.swing.*;
11. import java.awt.event.*;
12. public class QQClient {
13. private JFrame f=new JFrame("QQ客户端");
14. private TextArea t1=new TextArea();
15. private TextArea t2=new TextArea();
16. private Button b=new Button("发送");
17. //一下是 网络通信用的变量
18. DataOutputStream dos=null;
19. BufferedReader br=null;
20. DataInputStream dis=null;
21. public void Addt1(String s){
22. t1.append(s);
23. }
24. public QQClient(){
25. f.setSize(400,300);
26. f.setLayout(new GridLayout(3,1));
27. t1.setEditable(false);  //不可编辑
28. f.add(t1);
29. f.add(t2);
30. f.add(b);
31. f.setVisible(true);
32. f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
33. b.addActionListener(new bListener());
34. }
35. public static void main(String[] args) throws Exception {
36. QQClient client=new QQClient();
37. InputStream in=null;
38. OutputStream out=null;
39. String string=null;
40. Socket s=new Socket("localhost",4545);
41. out=s.getOutputStream();
42. in=s.getInputStream();
43. client.dis=new DataInputStream(in);
44. client.dos=new DataOutputStream(out);
45. Listen2 l=new Listen2(client,client.dis);
46. Thread t=new Thread(l);
47. t.start();
48. }
49. class bListener implements ActionListener{
50. public void actionPerformed(ActionEvent e) {
51. try{
52. dos.writeUTF(t2.getText());
53. Addt1("发送："+"/n");
54. Addt1("    "+t2.getText()+"/n");
55. t2.setText("");
56. }catch(Exception ep){
57. }
58. }
59. }
60. }
61. class Listen2 implements Runnable{
62. private QQClient client=null;
63. private DataInputStream dis=null;
64. private String s=null;
65. Listen2(QQClient client,DataInputStream dis){
66. this.client=client;
67. this.dis=dis;
68. }
69. public void run() {
70. // TODO Auto-generated method stub
71. try{
72. while(true){
73. s=dis.readUTF();
74. client.Addt1("收到："+"/n");
75. client.Addt1("    "+s+"/n");
76. }
77. }catch(Exception e){
78. }
79. }
80. }