服务端

1. package 一对一用户;

6. import java.awt.BorderLayout;

7. import java.io.BufferedReader;

8. import java.io.IOException;

9. import java.io.InputStreamReader;

10. import java.io.PrintWriter;

11. import java.net.ServerSocket;

12. import java.net.Socket;

13. import java.util.Vector;

14. import javax.swing.JFrame;

15. import javax.swing.JScrollPane;

16. import javax.swing.JTextArea;

18. public class fuwuchuangkou extends JFrame {

19. private JTextArea ta_info;

20. private ServerSocket server; // 声明ServerSocket对象

21. private Socket socket; // 声明Socket对象socket

22. private Vector<Socket> vector = new Vector<Socket>();// 用于存储连接到服务器的客户端套接字对象

24. public void createSocket() {

25. try {

26. server = new ServerSocket(1978);

27. while (true) {

28. ta_info.append("等待新客户连接......\n");

29. socket = server.accept();// 创建套接字对象

30. vector.add(socket);// 将套接字对象添加到向量对象中

31. ta_info.append("客户端连接成功。" + socket + "\n");

32. new ServerThread(socket).start();// 创建并启动线程对象

33. }

34. } catch (IOException e) {

35. e.printStackTrace();

36. }

37. }

39. class ServerThread extends Thread {

40. Socket socket;

41. public ServerThread(Socket socket) {

42. this.socket = socket;

43. }

44. public void run() {

45. try {

46. BufferedReader in = new BufferedReader(new InputStreamReader(

47. socket.getInputStream()));// 创建输入流对象

48. while (true) {

49. String info = in.readLine();// 读取信息

50. for (Socket s : vector) {// 遍历所有客户端套接字对象

51. if (s != socket) {// 如果不是发送信息的套接字对象

52. PrintWriter out = new PrintWriter(s

53. .getOutputStream(), true);// 创建输出流对象

54. out.println(info);// 发送信息

55. out.flush();// 刷新输出缓冲区

56. }

57. }

58. }

59. } catch (IOException e) {

60. ta_info.append(socket + "已经退出。\n");

61. vector.remove(socket);// 移除退出的客户端套接字

62. }

63. }

64. }

67. public static void main(String args[]) {

68. fuwuchuangkou frame = new fuwuchuangkou();

69. frame.setVisible(true);

70. frame.createSocket();

71. }

73. /**

74. * Create the frame

75. */

76. public fuwuchuangkou() {

77. super();

78. setTitle("一对一");

79. setBounds(100, 100, 385, 266);

80. setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

82. final JScrollPane scrollPane = new JScrollPane();

83. getContentPane().add(scrollPane, BorderLayout.CENTER);

85. ta_info = new JTextArea();

86. scrollPane.setViewportView(ta_info);

87. }

88. }

客户端

1. package 一对一用户;

4. import java.awt.BorderLayout;

5. import java.awt.Dimension;

6. import java.awt.EventQueue;

7. import java.awt.event.ActionEvent;

8. import java.awt.event.ActionListener;

9. import java.io.BufferedReader;

10. import java.io.IOException;

11. import java.io.InputStreamReader;

12. import java.io.PrintWriter;

13. import java.net.Socket;

14. import java.net.UnknownHostException;

15. import javax.swing.JButton;

16. import javax.swing.JFrame;

17. import javax.swing.JLabel;

18. import javax.swing.JPanel;

19. import javax.swing.JScrollPane;

20. import javax.swing.JTextArea;

21. import javax.swing.JTextField;

23. public class kehuchuangkou extends JFrame {

24. private JTextArea ta_info;

25. private JTextField tf_send;

26. PrintWriter out;// 声明输出流对象

28. /**

29. * Launch the application

30. *

31. * @param args

32. */

33. public static void main(String args[]) {

34. EventQueue.invokeLater(new Runnable() {

35. public void run() {

36. try {

37. kehuchuangkou frame = new kehuchuangkou();

38. frame.setVisible(true);

39. frame.createClientSocket();

40. } catch (Exception e) {

41. e.printStackTrace();

42. }

43. }

44. });

45. }

47. public void createClientSocket() {

48. try {

49. Socket socket = new Socket("127.0.0.1", 1978);// 连接本地1978端口

50. out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象

51. new ClientThread(socket).start();// 创建并启动线程对象

52. } catch (UnknownHostException e) {

53. e.printStackTrace();

54. } catch (IOException e) {

55. e.printStackTrace();

56. }

57. }

59. class ClientThread extends Thread {

60. Socket socket;

62. public ClientThread(Socket socket) {

63. this.socket = socket;

64. }

66. public void run() {

67. try {

68. BufferedReader in = new BufferedReader(new InputStreamReader(

69. socket.getInputStream()));// 创建输入流对象

70. while (true) {

71. String info = in.readLine();// 读取信息

72. ta_info.append(info + "\n");// 在文本域中显示信息

73. if (info.equals("88")) {

74. break;// 结束线程

75. }

76. }

77. } catch (IOException e) {

78. e.printStackTrace();

79. }

80. }

81. }

82. private void send() {

83. String info = tf_send.getText();// 获得输入的信息

84. if (info.equals("")) {

85. return;// 如果没输入信息则返回，即不发送

86. }

87. if (info.equals("88")) {

88. System.exit(0);// 如果没输入信息是88，则退出

89. }

90. out.println(info);// 发送信息

91. out.flush();// 刷新输出缓冲区

92. tf_send.setText(null);// 清空文本框

93. }

96. public kehuchuangkou() { //创建面板

97. super();

98. setTitle("一对一");

99. setBounds(100, 100, 385, 266);

100. setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

102. final JPanel panel = new JPanel();

103. getContentPane().add(panel, BorderLayout.SOUTH);

105. final JLabel label = new JLabel();

106. label.setText("输入聊天内容：");

107. panel.add(label);

109. tf_send = new JTextField();

110. tf_send.addActionListener(new ActionListener() {

111. public void actionPerformed(final ActionEvent e) {

112. send();

113. }

114. });

115. tf_send.setPreferredSize(new Dimension(180, 25));

116. panel.add(tf_send);

118. final JButton button = new JButton();

119. button.addActionListener(new ActionListener() {

120. public void actionPerformed(final ActionEvent e) {

121. send();

122. }

123. });

124. button.setText("发 送");

125. panel.add(button);

127. final JScrollPane scrollPane = new JScrollPane();

128. getContentPane().add(scrollPane, BorderLayout.CENTER);

130. ta_info = new JTextArea();

131. scrollPane.setViewportView(ta_info);

133. }

135. }

1. package 一对一用户;

5. import java.awt.BorderLayout;

6. import java.awt.Dimension;

7. import java.awt.EventQueue;

8. import java.awt.event.ActionEvent;

9. import java.awt.event.ActionListener;

10. import java.io.BufferedReader;

11. import java.io.IOException;

12. import java.io.InputStreamReader;

13. import java.io.PrintWriter;

14. import java.net.Socket;

15. import java.net.UnknownHostException;

16. import javax.swing.JButton;

17. import javax.swing.JFrame;

18. import javax.swing.JLabel;

19. import javax.swing.JPanel;

20. import javax.swing.JScrollPane;

21. import javax.swing.JTextArea;

22. import javax.swing.JTextField;

24. public class kehu1 extends JFrame {

25. private JTextArea ta_info;

26. private JTextField tf_send;

27. PrintWriter out;// 声明输出流对象

29. /**

30. * Launch the application

31. *

32. * @param args

33. */

34. public static void main(String args[]) {

35. EventQueue.invokeLater(new Runnable() {

36. public void run() {

37. try {

38. kehuchuangkou frame = new kehuchuangkou();

39. frame.setVisible(true);

40. frame.createClientSocket();

41. } catch (Exception e) {

42. e.printStackTrace();

43. }

44. }

45. });

46. }

48. public void createClientSocket() {

49. try {

50. Socket socket = new Socket("127.0.0.1", 1978);// 连接本地1978端口

51. out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象

52. new ClientThread(socket).start();// 创建并启动线程对象

53. } catch (UnknownHostException e) {

54. e.printStackTrace();

55. } catch (IOException e) {

56. e.printStackTrace();

57. }

58. }

60. class ClientThread extends Thread {

61. Socket socket;

63. public ClientThread(Socket socket) {

64. this.socket = socket;

65. }

67. public void run() {

68. try {

69. BufferedReader in = new BufferedReader(new InputStreamReader(

70. socket.getInputStream()));// 创建输入流对象

71. while (true) {

72. String info = in.readLine();// 读取信息

73. ta_info.append(info + "\n");// 在文本域中显示信息

74. if (info.equals("88")) {

75. break;// 结束线程

76. }

77. }

78. } catch (IOException e) {

79. e.printStackTrace();

80. }

81. }

82. }

83. private void send() {

84. String info = tf_send.getText();// 获得输入的信息

85. if (info.equals("")) {

86. return;// 如果没输入信息则返回，即不发送

87. }

88. if (info.equals("88")) {

89. System.exit(0);// 如果没输入信息是88，则退出

90. }

91. out.println(info);// 发送信息

92. out.flush();// 刷新输出缓冲区

93. tf_send.setText(null);// 清空文本框

94. }

97. public kehu1() { //创建面板

98. super();

99. setTitle("一对一");

100. setBounds(100, 100, 385, 266);

101. setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

103. final JPanel panel = new JPanel();

104. getContentPane().add(panel, BorderLayout.SOUTH);

106. final JLabel label = new JLabel();

107. label.setText("输入聊天内容：");

108. panel.add(label);

110. tf_send = new JTextField();

111. tf_send.addActionListener(new ActionListener() {

112. public void actionPerformed(final ActionEvent e) {

113. send();

114. }

115. });

116. tf_send.setPreferredSize(new Dimension(180, 25));

117. panel.add(tf_send);

119. final JButton button = new JButton();

120. button.addActionListener(new ActionListener() {

121. public void actionPerformed(final ActionEvent e) {

122. send();

123. }

124. });

125. button.setText("发 送");

126. panel.add(button);

128. final JScrollPane scrollPane = new JScrollPane();

129. getContentPane().add(scrollPane, BorderLayout.CENTER);

131. ta_info = new JTextArea();

132. scrollPane.setViewportView(ta_info);

134. }

136. }

运行结果如下：