网络Socket编程（简易qq实现之C/S通信1）

1. 目标：实现两个用户之间的通信，利用的是简单的Socket知识以及简略界面

2. 界面：分为客户端与服务器端（如下图）

3. 基本功能：客户端先向服务器端发送一个消息，这样就可以让客户端与服务器端实现持续通信

4. 代码实现：

（1）服务器端代码

package com.test;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

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

public class QQServer extends JFrame implements ActionListener{
    JTextArea jta;
    JTextField jtf;
    JButton jb;
    JScrollPane jsp;
    JPanel jpn;
    
    PrintWriter pw;
    /**
     * @param args
     */
    public static void main(String[] args) {
        QQServer qq = new QQServer();
        qq.init();
    }
    public QQServer(){
        //页面布局
        jta = new JTextArea();
        jtf = new JTextField(10);
        jb  = new JButton("发送");
        jb.addActionListener(this);//事件监听
        jsp = new JScrollPane(jta);
        jpn = new JPanel();
        
        jpn.add(jtf);
        jpn.add(jb);
        
        this.add(jsp,"Center");
        this.add(jpn,"South");
        this.setTitle("简易qq服务器端");
        
        this.setSize(300,200);
        this.setVisible(true);
    }
    public void init(){
        try {
            //服务器监听端口
            System.out.println("服务器在监听.....");
            ServerSocket ss = new ServerSocket(9992);
            Socket s = ss.accept();
            //服务器接收流
            InputStreamReader isr = new InputStreamReader(s.getInputStream());
            BufferedReader br = new BufferedReader(isr);
            //服务器输出
            pw = new PrintWriter(s.getOutputStream(), true);
            while (true) {
                //持续接收从客户端信息并显示
                String info = br.readLine();
                jta.append("客户端对服务器端说:"+info+"
");
            }
        } catch (Exception e) {
            // TODO: handle exception
        }
    }
    @Override
    public void actionPerformed(ActionEvent e) {
        //在Jtextfield内获取文字，并发送给客户端
        if(e.getSource()==jb){
            String msg = jtf.getText();
            jta.append("服务器对客户端说："+msg+"
");
            pw.println(msg);
            jtf.setText("");
        }
        
    }

}

（2）客户端代码

package com.test;
/**
 * 简易qq,服务器端实现
 */
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

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

public class QQClient extends JFrame implements ActionListener{
    JTextArea jta;//
    JTextField jtf;
    JButton jb;
    JScrollPane jsp;
    JPanel jpn;
    
    PrintWriter pw;
    public static void main(String[] args) {
        QQClient qq = new QQClient();
        qq.init();
    }
    public QQClient(){
        //界面布局
        jta = new JTextArea();
        jtf = new JTextField(10);
        jb  = new JButton("发送");
        jb.addActionListener(this);
        jsp = new JScrollPane(jta);
        jpn = new JPanel();
        
        jpn.add(jtf);
        jpn.add(jb);
        
        this.add(jsp,"Center");
        this.add(jpn,"South");
        this.setTitle("简易qq 客户端");
        
        this.setSize(300,200);
        this.setVisible(true);
        
    }
    public void init(){
        try {
            //客户端请求服务器
            Socket s = new Socket("127.0.0.1",9992);
            //客户端接收流
            InputStreamReader isr = new InputStreamReader(s.getInputStream());
            BufferedReader br = new BufferedReader(isr);
            //客户端输出
            pw = new PrintWriter(s.getOutputStream(), true);
            while (true) {
                //持续接收从服务器信息并显示
                String info = br.readLine();
                jta.append("服务器端对客户端说："+info+"
");
            }
        } catch (Exception e) {
            // TODO: handle exception
        }
    }
    @Override
    public void actionPerformed(ActionEvent e) {
        //在Jtextfield内获取文字，并发送给服务器端
        if(e.getSource()==jb){
            String msg = jtf.getText();
            jta.append("客户端对服务器端说："+msg+"
");
            pw.println(msg);
            jtf.setText("");
        }
        
    }

}