socket及时通讯程序

[/size]java socket 实现及时通讯
对于Java Socket编程而言，有两个概念，一个是ServerSocket，一个是Socket。服务端和客户端之间通过Socket建立连接，之后它们就可以进行通信了。首先ServerSocket将在服务端监听某个端口，当发现客户端有Socket来试图连接它时，它会accept该Socket的连接请求，同时在服务端建立一个对应的Socket与之进行通信。这样就有两个Socket了，客户端和服务端各一个。

       对于Socket之间的通信其实很简单，服务端往Socket的输出流里面写东西，客户端就可以通过Socket的输入流读取对应的内容。Socket与Socket之间是双向连通的，所以客户端也可以往对应的Socket输出流里面写东西，然后服务端对应的Socket的输入流就可以读出对应的内容。

下面是及时通讯实现的程序
1.新建socket server服务器端
/**//*
*服务端
*/
package edu.jlu.fuliang;

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;

public class Server extends JFrame implements Runnable {
private ServerSocket server;
private Socket connection;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;

public static void main(String args[]) {
  Server s = new Server();
  s.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}

public Server() {
  super("Server");
  startButton = new JButton("Start the server");
  text1 = new JTextField(20);
  display = new JTextArea(7, 30);
  display.setEditable(false);
Container container = getContentPane();
  container.setLayout(new BorderLayout());
  container.add(startButton,BorderLayout.NORTH);
  container.add(new JScrollPane(display),BorderLayout.CENTER);
  container.add(text1,BorderLayout.SOUTH);

/**//*
   * 给开始按钮添加监听器。
   */
  startButton.addActionListener(new ActionListener(){
   public void actionPerformed(ActionEvent e) {
    display.setText("启动服务器 ");
    startButton.setEnabled(false);
    try {
     //端口设为5000，最大连接请求为100个
     server = new ServerSocket(5000, 100);
     connection = server.accept();
     output = connection.getOutputStream();
     input = connection.getInputStream();
     output.write("连接成功! ".getBytes());
     outThread = new Thread(Server.this);
     outThread.start();
     } catch (IOException ee) {
    }
   }
  });
 
  /**//*
  /*给文本域添加键盘监听器，按回车发送信息。
        */
 
  text1.addKeyListener(new KeyAdapter(){
   public void keyPressed(KeyEvent ke) {
    if(ke.getKeyCode() == KeyEvent.VK_ENTER){
     byte writeBytes[] = new byte[50];
     String s = "Server:" + text1.getText();
     text1.setText("");
     writeBytes = s.getBytes();
     display.append(s+"\n");
     try {
      output.write(writeBytes);
     } catch (IOException ee) {
     }
     if (s.trim().equals("Server: exit")) {
      outThread.stop();
      quit();
     }
    }
   }
  });
  setSize(300, 400);
  setResizable(false);
  setVisible(true);
}

public void run() {
  while (true) {
   byte readBytes[] = new byte[50];
   try {
    input.read(readBytes);//读去对方发送的消息
   } catch (IOException e) {
   }
   String s = new String(readBytes);
   display.append(s+"\n");
   if (s.trim().equals("Client: exit"))
    break;
  }
  quit();
}

public void quit() {
  try {
   output.close();
   input.close();
   connection.close();
  } catch (IOException e) {
  }
  startButton.setEnabled(true);
}
}

2.建立socket客户端
package edu.jlu.fuliang;

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.RandomAccessFile;
import java.net.Socket;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;

public class Client extends JFrame implements Runnable {
private Socket client;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;
private JMenu loginMenu = new JMenu("登录");
private JMenuItem register = new JMenuItem("注册");
private JMenuItem login = new JMenuItem("登录");
private JMenuBar bar = new JMenuBar();
private Register registerDlg ;
private Login loginDlg;
private RandomAccessFile file;

public static void main(String args[]) {
  Client c = new Client();
  c.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}

public Client() {
  super("Client");
  startButton = new JButton("Connect to server");
  text1 = new JTextField(20);
  display = new JTextArea(7, 30);
  display.setEditable(false);
   loginMenu.add(register);
  loginMenu.add(login);
  bar.add(loginMenu);
  setJMenuBar(bar);
  Container container = getContentPane();
  container.setLayout(new BorderLayout());
  container.add(startButton,BorderLayout.NORTH);
  container.add(new JScrollPane(display),BorderLayout.CENTER);
  container.add(text1,BorderLayout.SOUTH);

  try {
     file = new RandomAccessFile(new File("E://login.txt"),"rw");
  } catch (IOException e1) {
   e1.printStackTrace();
  }
  registerDlg = new Register(this,file);
  loginDlg = new Login(this,file);
  startButton.addActionListener(new ActionListener(){
   public void actionPerformed(ActionEvent e) {
    display.setText("连接服务器");
    startButton.setEnabled(false);
    try {
     client = new Socket("127.0.0.1", 5000);
     output = client.getOutputStream();
     input = client.getInputStream();
     outThread = new Thread(Client.this);
     outThread.start();
    } catch (IOException ee) {
    }
   }
  });
  text1.addKeyListener(new KeyAdapter(){
   public void keyPressed(KeyEvent ke) {
   if(ke.getKeyCode() == KeyEvent.VK_ENTER){
    byte writeBytes[] = new byte[50];
    String s = loginDlg.getLoginName()+": " + text1.getText();
    text1.setText("");
    writeBytes = s.getBytes();
    display.append(s+"\n");
    try {
     output.write(writeBytes);
    } catch (IOException ee) {
    }
    if (s.trim().equals(loginDlg.getLoginName()+": exit")) {
     outThread.stop();
     quit();
    }
   }
   }
  });
  register.addActionListener(new ActionListener(){
   public void actionPerformed(ActionEvent e) {
    registerDlg.setVisible(true);
   }
  });
  login.addActionListener(new ActionListener(){
   public void actionPerformed(ActionEvent e) {
    loginDlg.setVisible(true);
   }
  });
  setSize(300, 400);
  setResizable(false);
  setVisible(true);
}

public void run() {
  while (true) {
   byte readBytes[] = new byte[1024];
   try {
    input.read(readBytes);
   } catch (IOException e) {
   }
   String s = new String(readBytes);
   display.append(s+"\n");
   if (s.trim().equals("Server: exit"))
    break;
  }
  quit();
}

public void quit() {
  try {
   output.close();
   input.close();
   client.close();
  } catch (IOException e) {
  }
  startButton.setEnabled(true);
}
}
3.注册弹窗口
package edu.jlu.fuliang;

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.RandomAccessFile;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JTextField;


public class Register extends JDialog{
private String nickName;
private JTextField textField;
private JButton registerButton;
private RandomAccessFile file;////保存注册信息的文件

public Register(JFrame f,RandomAccessFile file){
  super(f,"注册",false);
  this.file = file;
  JPanel panel = new JPanel();
  panel.add(new JLabel("昵称:"));
  textField = new JTextField(10);
  panel.add(textField);
  Container container = getContentPane();
  container.setLayout(new BorderLayout());
  container.add(panel,BorderLayout.NORTH);
  registerButton = new JButton("注册");
  container.add(registerButton,BorderLayout.SOUTH);
  setVisible(false);
  setBounds(100,200,200,200);
  registerButton.addActionListener(new RegisterListener());
}
/**//*
  * 注册监听器，当单击登注册按钮时，触发该事件
  * 并向文件中写入注册信息。
  */
private class RegisterListener implements ActionListener{
public void actionPerformed(ActionEvent e) {
  try {
   file.seek(file.length());
   String  str = textField.getText();
   textField.setText("");
   file.writeUTF(str);
   Register.this.setVisible(false);
  } catch (IOException e1) {
   e1.printStackTrace();
  }
}
}
}
4.登陆弹出窗口
package edu.jlu.fuliang;

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.RandomAccessFile;

import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextField;


public class Login extends JDialog{
private JTextField textField;
private JButton loginButton;
private RandomAccessFile file;//保存注册信息的文件
private String loginName = "guest";//保存登录者的名字，为登陆为guest;

public Login(JFrame f,RandomAccessFile file){
  super(f,"登陆",false);
  this.file = file;
  JPanel panel = new JPanel();
  panel.add(new JLabel("昵称:"));
  textField = new JTextField(10);
  panel.add(textField);
  Container container = getContentPane();
  container.setLayout(new BorderLayout());
  container.add(panel,BorderLayout.NORTH);
  loginButton = new JButton("登陆");
  container.add(loginButton,BorderLayout.SOUTH);
  setVisible(false);
  setBounds(100,200,200,200);
  loginButton.addActionListener(new LoginListener());
}

public String getLoginName(){
  return loginName;
}

/**//*
  * 登录监听器，当单击登陆按钮时，触发该事件
  * 从文件中读取并查找是否注册过，如果没有找
  * 到则弹出未注册警告。否则弹出欢迎对话框表
  * 示欢迎
  */
private class LoginListener implements ActionListener{
public void actionPerformed(ActionEvent e) {
  boolean flag = false;
  try {
   String name = textField.getText().trim();
   textField.setText("");
   file.seek(0);
   while(file.getFilePointer() < file.length()){
    String nik = file.readUTF();
    if(nik.equals(name)){
     flag = true;
     loginName = name;
     break;
    }
   }
   if(!flag){
    String warning="没有找到你的账号请先注册!";
             JOptionPane.showMessageDialog(Login.this,warning,"警告",JOptionPane.WARNING_MESSAGE);
   }else{
    String welcome="欢迎来聊天!";
             JOptionPane.showMessageDialog(Login.this,welcome,"欢迎",JOptionPane.WARNING_MESSAGE);
   }
   Login.this.setVisible(false);
  } catch (IOException e1) {
   e1.printStackTrace();
  }
}
}
}