socket及时通讯程序 -

open023

浏览: 185533 次
性别:
来自: 深圳

最近访客更多访客>>

leimingchao

wt_7628

乐道如生

柔柔的哥哥

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

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();
}
}
}
}