Java世界

学习笔记

常用链接

统计

积分与排名

天籁村

新华网

雅虎

最新评论

简易的聊天软件

用两个类来实现,一个Server类和Client类,在MyEclipse下调试通过。

Server类:
/**
 * 聊天软件Server程序段
 * @author Rabbit
 * @version 0.9 2007-11-6
 */
package com.sinojava.three;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class Server {
 private JFrame frame;
 private JTextField enter;
 private JTextArea display;
 private ObjectOutputStream output;
 private ObjectInputStream input;
 private ServerSocket ser;
 private Socket soc;
 private Container container;
 private int counter = 0;
 //服务器端GUI
 public Server() {
  frame = new JFrame("服务器端");
  container = frame.getContentPane();
  enter = new JTextField();
  enter.setEnabled(false);
  enter.addActionListener(new ActionListener() {
   public void actionPerformed(ActionEvent e) {
    sendData(e.getActionCommand());
   }
  });
  container.add(enter,BorderLayout.NORTH);
  display = new JTextArea();
  container.add(new JScrollPane(display),BorderLayout.CENTER);
  frame.setSize(400,400);
  frame.setVisible(true);
  frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
 }
 private void sendData(String message) {
       // 向客户端发送信息
       try {
          output.writeObject("服务器>>>"+message);
          output.flush();
          display.append("\n服务器>>>"+message);
       }
       catch (IOException e) {
          display.append("\n错误写入对象");
       }
    }
  public void runServer() {   
       try {
          // 第一步:创建一个ServerSocket
          ser = new ServerSocket(5000,100);
          while(true) {
           counter++;
             // 第二步:等待一个连接
             waitForConnection();
             // 第三步:获取接受数据
             getStreams();
             // 第四步:连接处理
             processConnection();
             // 第五步:关闭连接
             closeConnection();
          }
       }catch (IOException e) {
          e.printStackTrace();
       }
    }
  //等待连接服务器
  private void waitForConnection() throws IOException {
   display.setText("等待连接\n");
      soc = ser.accept();   
      //InetAddress类采用工厂设计模式,有三个静态工厂方法,如getHostName or getLocalHost。
      display.append("Socket "+counter+" 接收来至:"+soc.getInetAddress().getHostName());
  }
    // 获取接受数据
  private void getStreams() throws IOException {
      output = new ObjectOutputStream(soc.getOutputStream());
      output.flush();
      input = new ObjectInputStream(soc.getInputStream());
      display.append("\n获得I/O流\n");
  }
    // 连接处理
  private void processConnection() throws IOException {
      String message ="服务器: 连接成功\n";
      output.writeObject(message);
      output.flush();
      enter.setEnabled(true);
      do {
          try {
             message = (String)input.readObject();
             enter.setText(null);
             display.append("\n"+message);
             display.setCaretPosition(display.getText().length());
          }
          catch(ClassNotFoundException e) {
             display.append("\n未知对象类型接收");
          }
       } while (!message.equals("客户端>>>终端"));
    }
  //关闭Socket
  private void closeConnection() throws IOException {
      display.append("\n用户终端连接");
      enter.setEnabled(false);
      output.close();
      input.close();
      soc.close();
  }
  public static void main(String args[]) {
   Server server = new Server();
   server.runServer();
  }
}

Client类:
/**
 * 聊天软件Client程序段
 * @author Rabbit
 * @version 0.9 2007-11-6
 */
package com.sinojava.three;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class Client {
   private JFrame frame;
   private JTextField enter;
   private JTextArea display;
   private ObjectOutputStream output;
   private ObjectInputStream input;
   private String message = "";
   private String chatServer;
   private Socket soc;
   private Container container;
   // 客户端GUI
   public Client(String host) {
      frame = new JFrame("客户端");
      // 设置服务器到客户端连接
      chatServer = host;
      container = frame.getContentPane();
      enter = new JTextField();
      enter.setEnabled(false);
      enter.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
               sendData(e.getActionCommand());           
            }
         });
      container.add(enter,BorderLayout.NORTH);
      display = new JTextArea();
      container.add(new JScrollPane(display),BorderLayout.CENTER);
      frame.setSize(400,400);
      frame.setVisible(true);
      frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
   }
   // 连接服务器处理信息
   public void runClient() {
      try {
         // 第一步:创建一个Socket,连接服务器
         connectToServer();
         // 第二步:获取接受数据
         getStreams();
         // 第三步:连接处理
         processConnection();
         // 第四步:关闭连接
         closeConnection();
      }
      catch (IOException e) {
         e.printStackTrace();
      }
   }
   // 获取接受数据
   private void getStreams() throws IOException {
      output = new ObjectOutputStream(soc.getOutputStream());
      output.flush();     
      input = new ObjectInputStream(soc.getInputStream());
      display.append("\n获得I/O流\n");
   }
   // 创建一个Socket,连接服务器
   private void connectToServer() throws IOException {     
      display.setText("连接中\n");
      //InetAddress类采用工厂设计模式,有三个静态工厂方法,如getByName。
      soc = new Socket(InetAddress.getByName(chatServer),5000);
      display.append("连接到:"+soc.getInetAddress().getHostName());
   }
   // 连接处理
   private void processConnection() throws IOException {
      enter.setEnabled(true);
      do {
         try {
            message = (String)input.readObject();
            enter.setText("");
            display.append("\n"+message);
            display.setCaretPosition(display.getText().length());
         }
         catch (ClassNotFoundException e) {
            display.append("\n没有对象接受");
         }
      } while (!message.equals("服务器>>>终端"));
   } 
   // 关闭连接
   private void closeConnection() throws IOException {
      display.append("\n关闭连接");
      output.close();
      input.close();
      soc.close();
   }
   // 发送信息到服务器
   private void sendData(String message) {
      try {
         output.writeObject("客户端>>>"+message);
         output.flush();
         display.append("\n客户端>>>"+message);
      }
      catch (IOException e) {
         display.append("\n错误的对象");
      }
   }
   public static void main(String args[]) {
      Client client = new Client("127.0.0.1");
      client.runClient();
   }

 


 

posted on 2007-11-06 15:27 Rabbit 阅读(346) 评论(0)  编辑  收藏


只有注册用户登录后才能发表评论。


网站导航: