八.网络编程

网络编程的基本概念

   ·网络的概念

　　

   ·网络连接的功能

　　

   ·网络编程的三要素

　　（建议使用10000以上）

IP和端口和Socket含义

   ·IP地址

　　

   ·端口号

  　　

   ·Socket

　　

TCP和UDP协议的区别

   ·TCP

　　

　　特点：1.面向连接；

　　　　　2.点到点的通信；

　　　　　3.高可靠性，三次握手；

　　　　　4.占用系统资源多，效率低

　　举例：打电话，发视频

   ·UDP

　　

　　特点：

　　　　

   ·TCP和UDP的区别

　　

TCP协议数据传递细节

   ·TCP通信原理

　　服务器端创建serversocket，在指定端口监听并处理请求；

　　客户端创建socket，向服务器端发送请求

　　

UDP协议数据传递细节

   ·UDP协议数据传递细节

　　

　　

 InetAddress类_InetSocketAddress类

   ·InetAddress类

　　封装计算机IP的地址，不包含端口号。

   ·InetAddress类常用的方法

　　

   ·InetSocketAddress类

　　此类用于实现IP套接字地址（IP地址+端口号），用于socket通信

URL类

   ·URL类

　　统一资源定位符，由4部分组成：协议，存放资源的主机的端口，IP，资源文件名。

　　　　例如：

　　URL是指向互联网资源的指针。

　　　　

   ·常用方法

　　

   ·网络爬虫

　　（需要用到java.net.URL中的openstream()方法）　

package com.zqf.urlProject;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;

public class TestUrl {
    public static void main(String[] args) throws IOException {
        /**网络爬虫
         * （1）从网络上获取资源 www.baidu.com
         * （2）存储到本地
         */
        //(1)创建URL对象
        URL url = new URL("http://www.baidu.com");    //主页资源
        //(2)获取字节输入流
        InputStream is=url.openStream();
        //(3)缓冲流
        BufferedReader br= new BufferedReader(new InputStreamReader(is,"utf-8"));
        //(4)存储到本地
        BufferedWriter bw= new BufferedWriter(new OutputStreamWriter(new FileOutputStream("index.html"),"utf-8"));
        //(5)边读边写
        String line = null;
        while ((line=br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //(6)关资源
        bw.close();
        br.close();
    }
}

 基于TCP协议的socket编程_单次通信_实现单次请求与响应                                           

   ·传递单个字符

package com.zqf.serverProject;

import java.io.OutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class server {
    public static void main(String[] args) throws IOException {
        System.out.println("-----服务器端以及启动---------");
        //(1)创建ServerSocket对象
        ServerSocket server = new ServerSocket(9999);
        //(2)监听是否有客服端来请求连接
        Socket client = server.accept();
        //(3)获取输入流
        InputStream is = client.getInputStream();
        System.out.println((char)is.read());
        //(4)获取输出流
        //“收到了”
        OutputStream os = client.getOutputStream();
        os.write("收到了!".getBytes());
        //(5)关闭流，关闭Socket
        if(os!=null){
            os.close();
        }
        if(is!=null){
            is.close();
        }
        if(client!=null){
            client.close();
        }
    }

}

package com.zqf.clientProject;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class client {
    public static void main(String[] args) throws IOException {
        //(1)创建Socket对象
        Socket client = new Socket("192.168.6.1",9999);
        //(2)获取输出流
        OutputStream os = client.getOutputStream();
        os.write('a');
        //(3)获取输入流
        InputStream is = client.getInputStream();
        byte [] buf = new byte[1024];    //存到byte类型的数组当中，   （中转站）
        int len = 0 ;    //    读到的字节的个数
        while((len=is.read(buf))!=-1){
            System.out.println(new String (buf,0,len));
        }
        //(4)关闭流
        if(is!=null){
            is.close();
        }
        if(os!=null){
            os.close();}
        if(client!=null){
            client.close();}
    }
}

   ·传递字符串

package com.zqf.serverProject;

import java.io.OutputStream;
import java.io.DataInput;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TestServer {
    public static void main(String[] args) throws IOException {
        System.out.println("-----服务器端以及启动---------");
        //(1)创建ServerSocket对象
        ServerSocket server = new ServerSocket(9999);
        //(2)监听是否有客服端来请求连接
        Socket client = server.accept();
        //(3)获取输入流
        DataInputStream dis = new DataInputStream(client.getInputStream());
        System.out.println(dis.readUTF());
        //(4)获取输出流
        //“收到了”
        DataOutputStream dos = new DataOutputStream(client.getOutputStream());
        dos.writeUTF("收到了");
        //(5)关闭流，关闭Socket
        if(dos!=null){
            dos.close();
        }
        if(dis!=null){
            dis.close();
        }
        if(client!=null){
            client.close();
        }
    }

}

package com.zqf.clientProject;

import java.io.DataInput;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class TestClient {
    public static void main(String[] args) throws IOException {
        //(1)创建Socket对象
        Socket client = new Socket("192.168.6.1",9999);
        //(2)获取输出流
        DataOutputStream dos = new DataOutputStream(client.getOutputStream());
        dos.writeUTF("helloworle");
        //(3)获取输入流
        DataInputStream dis = new DataInputStream(client.getInputStream());
        System.out.println(dis.readUTF());
        //(4)关闭流
        if(dis!=null){
            dis.close();
        }
        if(dos!=null){
            dos.close();}
        if(client!=null){
            client.close();}
    }
}

基于TCP协议的Socket编程_双向通信_实现模拟用户登录

 　　

   ·多用户登录是实现：

　　

package com.bjsxt.entity;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Scanner;

public class Client {
    public static void main(String[] args) throws IOException {
        //(1)创建Socket对象，用于连接服务器
        Socket client=new Socket("localhost", 8888);
        //(2)获取输出流  (对象流)
        ObjectOutputStream oos=new ObjectOutputStream(client.getOutputStream());
        //(3)创建User对象
                  //调用获取用户对象的方法
        User u=getUser();//new User("bjsxt", "bjsxt");
        //(4)User对象发送到服务器
        oos.writeObject(u);
        
        //(5)获取输入流（数据流）
        DataInputStream dis=new DataInputStream(client.getInputStream());
        System.out.println(dis.readUTF());
        //(6)关闭流
        if(dis!=null){
            dis.close();
        }
        if(oos!=null){
            oos.close();
        }
        if(client!=null){
            client.close();
        }
    }
    //获取用户对象的方法
    public static User getUser(){
        Scanner input=new Scanner(System.in);
        System.out.println("请输入用户名:");
        String userName=input.next();
        System.out.println("请输入密码:");
        String password=input.next();
        //封装成User对象
        return new User(userName,password);
    }
}

package com.bjsxt.entity;

import java.io.Serializable;

public class User implements Serializable {//用于封装用户名和密码，
    
    /**
     * 
     */
    private static final long serialVersionUID = -2618388865354437739L;
    private String userName;
    private String password;
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public User(String userName, String password) {
        super();
        this.userName = userName;
        this.password = password;
    }
    public User() {
        super();
    }
    
}

package com.bjsxt.server;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

import com.bjsxt.entity.User;
import com.bjsxt.thread.ServerThread;

public class Server {
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        System.out.println("----------------------服务器端已启动---------------------");
        //(1)创建ServerSocket对象
        ServerSocket server=new ServerSocket(8888);
        
        while(true){
            Socket socket=server.accept();
            //创建线程类的对象，并启动线程
            ServerThread st=new ServerThread(socket);
            //启动线程
            new Thread(st).start();
        }
    }
}

package com.bjsxt.thread;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.Socket;

import com.bjsxt.entity.User;

public class ServerThread implements Runnable{
    private Socket socket;//成员变量
    public ServerThread(Socket socket){
        this.socket=socket;
    }
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"请求登录");
        //(2)获取输入流--（对象流）
        ObjectInputStream ois=null;
        //(4)获取输出流(数据流)
        DataOutputStream dos=null;
        try {
            ois = new ObjectInputStream(socket.getInputStream());
                    User user=(User) ois.readObject();
                    
                    System.out.println(socket.getInetAddress().getHostAddress()+"请求登录:用户名"+user.getUserName()+"	密码:"+user.getPassword());
                    String str="";
                    //(3)对用户名和密码进行验证
                    if("bjsxt".equals(user.getUserName())&&"bjsxt".equals(user.getPassword())){
                        str="登录成功";
                    }else{
                        str="对不起，账号号密码不正确";
                    }
                    dos = new DataOutputStream(socket.getOutputStream());
                    dos.writeUTF(str);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
                //(5)关闭流
                if(dos!=null){
                    try {
                        dos.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(ois!=null){
                    try {
                        ois.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(socket!=null){
                    try {
                        socket.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
        }
        
    }
}

 

基于TCP协议的Socket编程_聊天室_客户端多线程