[Java]网络编程

package day13.me.net;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/** socket 编程 - 服务器端 */
public class MyTcpServer {
    private BufferedReader reader;
    private PrintWriter writer;
    private ServerSocket server;
    private Socket socket;

    void getServer() {
        try {
            server = new ServerSocket(8998);
            System.out.println("服务器套接字已经创建成功");
            while (true) {
                System.out.println("等待客户机连接");
                socket = server.accept();
                System.out.println("客户机连接成功");
                reader = new BufferedReader(new InputStreamReader(socket
                        .getInputStream()));
                writer = new PrintWriter(socket.getOutputStream(), true);
                getClientMessage();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void getClientMessage() {
        try {
            while (true) {
                if (reader.ready()) {
                    String s = reader.readLine();
                    System.out.println("客户机：" + s);
                    writer.println("Server Received:" + s);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        try {
            if (reader != null)
                reader.close();
            if (writer != null)
                writer.close();
            if (socket != null)
                socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        MyTcpServer tcpServer = new MyTcpServer();
        tcpServer.getServer(); // 调用方法
    }
}

package day13.me.net;

import java.awt.BorderLayout;
import java.awt.Container;
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.Socket;

import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.BevelBorder;

/** socket 编程 - 客户端 */
public class MyClient extends JFrame{
    
    private PrintWriter writer;
    private BufferedReader reader;
    Socket socket;
    private JTextArea ta = new JTextArea();
    private JTextField tf = new JTextField();
    Container cc;
    
    public MyClient(String title){
        super(title);
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        cc = this.getContentPane(); // 实例化对象，内容面板
        final JScrollPane scrollPane = new JScrollPane();
        scrollPane.setBorder(new BevelBorder(BevelBorder.RAISED));
        getContentPane().add(scrollPane,BorderLayout.CENTER);
        scrollPane.setViewportView(ta);
        cc.add(tf,"South");    // 将文本框放在窗体下部
        tf.addActionListener(new ActionListener(){
            public void actionPerformed(ActionEvent e){
                try{
                    writer.println(tf.getText());// 将文本框中信息写入流
                    ta.append(tf.getText()+‘\n‘    ); // 将文本框中信息显示在文本域中
                    ta.append(reader.readLine()+‘\n‘);
                    ta.setSelectionEnd(ta.getText().length());
                    tf.setText(""); // 将文本框清空        
                } catch(IOException ee){
                    ee.printStackTrace();
                }
            }
        });
    }

    private void connect() throws IOException{
        ta.append("尝试连接\n");
        String hostIP = "10.10.74.7";
        try{
            socket = new Socket("localhost",8998);
            writer = new PrintWriter(socket.getOutputStream(),true);
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            ta.append("完成连接\n");
        } catch(Exception e){
            e.printStackTrace();
        }
    }

    public static void main(String[] args) throws IOException{
        MyClient client = new MyClient("向服务器送数据");
        client.setSize(200,200);
        client.setLocation(700,300);
        client.setVisible(true);
        client.connect();
    }


}

package net;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;


public class Client {

    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        
        try {
            
            Socket socket = new Socket("10.10.74.2",8888);
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
            
            String line;

            while( !(line = in.readLine()).equals("bye")){
                
                
                bw.write(line);
                bw.flush();
                System.out.println("服务端:" + br.readLine());
                
            }
            
            socket.close();
            
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }

}

package net;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * ServerSocket，顾名思义，是用来监听端口并接受用户连接的。
 * 我们创建一个 ServerSocket，在构造函数里把想要监听的端口传给它，它就绑定了我们所指定的端口。
 * 当我们调用 accept 方法的时候，程序就进入了阻塞状态，也就是说停在 accept 这句不再往下运行了，等待用户连接。
 * 当一个用户连接到指定的端口时，accept 方法返回一个 Socket，这个 Socket 就是我们用来与用户进行交互的通道。
 * 通过 Socket 我们可以获取一个 OutputStream 用来向客户端发送数据，也可以获取一个 InputStream 从客户端读取数据。
 */

public class ServerSocketDemo {
    
    public static void main(String[] args){
        
        try {
            
            ServerSocket server = new ServerSocket(8888);
            
            Socket socket = server.accept();
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));
            
            String line;
            while(true){
                                
                line = br.readLine();
                System.out.println(socket.getInetAddress().getHostAddress()+"->"+line);
                String line1 = br1.readLine();
                bw.write(line1);
                bw.flush();
                
            }
            
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }

}