Java基础笔记——网络编程TCP

 

//---------------------------------------------------------------------------服务器端多线程：就是和多个客户端连接
 1 package com.peng.Socket_TCP;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread extends Thread {
    // 和本线程相关的Socket
        Socket socket = null;

        public ServerThread(Socket socket) {
            this.socket = socket;
        }
        
        //线程执行的操作，响应客户端的请求
        public void run(){
            InputStream is=null;
            InputStreamReader isr=null;
            BufferedReader br=null;
            OutputStream os=null;
            PrintWriter pw=null;
            try {
                //获取输入流，并读取客户端信息
                is = socket.getInputStream();
                isr = new InputStreamReader(is);
                br = new BufferedReader(isr);
                String info=null;
                while((info=br.readLine())!=null){//循环读取客户端的信息
                    System.out.println("我是服务器，客户端说："+info);
                }
                socket.shutdownInput();//关闭输入流
                //获取输出流，响应客户端的请求
                os = socket.getOutputStream();
                pw = new PrintWriter(os);
                pw.write("欢迎！");
                pw.flush();//调用flush()方法将缓冲输出
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                //关闭资源
                try {
                    if(pw!=null)
                        pw.close();
                    if(os!=null)
                        os.close();
                    if(br!=null)
                        br.close();
                    if(isr!=null)
                        isr.close();
                    if(is!=null)
                        is.close();
                    if(socket!=null)
                        socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

}

//---------------------------------------------------------------------------单独连接

package com.peng.Socket_TCP;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
/*
 * 基于TCP的Socket通信：服务器和客户端----客户端类
 *         1、创建Socket类，设置连接服务器的主机和端口
 *         2、输出数据到服务器（注意关闭socket的输出流）
 *         3、输入服务器的响应（注意关闭socket的输入流）
 *         4、关闭资源
 * 
 *
 */
public class SingleConnect_client {

    public static void main(String[] args) {

        try {
            //1.创建客户端Socket，指定服务器地址和端口
            Socket socket=new Socket("192.168.2.100", 8884);
            //2.获取输出流，向服务器端发送信息
            OutputStream os=socket.getOutputStream();//字节输出流
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("呵呵呵呵");
            pw.flush();
            socket.shutdownOutput();//关闭输出流
            //3.获取输入流，并读取服务器端的响应信息
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            String info=null;
            while((info=br.readLine())!=null){
                System.out.println("我是客户端，服务器说："+info);
            }
            //4.关闭资源
            br.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

//---------------------------------------------------------------------------

package com.peng.Socket_TCP;

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
/*
 * 基于TCP的Socket通信：服务器和客户端----服务器类
 *         1、创建ServerSocket类，设置连接服务器的端口
 *         2、用ServerSocket对象的accept()方法创建socket对象
 *             3、输入客户端的数据（注意关闭socket的输入流）:socket.shutdownInput();
 *             4、输出响应到客户端（注意关闭socket的输出流）:socket.shutdownOutput();
 *         5、关闭资源
 * @author Lenovo
 *
 *
 *线程中就是端口指定，但是用循环来接受客户端的数据
 *
 *获取客户端的IP用的是        socket.getInetAddress()
 *获取Socket通信的输入流：    socket.getInputStream()     并包装
 *获取Socket通信的输出流：    socket.getOutputStream()    并包装
 *
 *
 */

public class SingleConnect_server {
    public static void main(String[] args) {
        try {
            //1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
            ServerSocket serverSocket=new ServerSocket(8888);
            Socket socket=null;
            
            //记录客户端的数量
            int count=0;
            System.out.println("***服务器即将启动，等待客户端的连接***");
            //循环监听等待客户端的连接
            while(true){
                //调用accept()方法开始监听，等待客户端的连接
                socket=serverSocket.accept();
                //创建一个新的线程
                ServerThread serverThread=new ServerThread(socket);
                //启动线程
                serverThread.start();
                
                count++;//统计客户端的数量
                System.out.println("客户端的数量："+count);
                InetAddress address=socket.getInetAddress();
                System.out.println("当前客户端的IP："+address.getHostAddress());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}