Socket实战与应用

1: Socket之序列化; 让对象能够通过socket进行传输

服务端：

package com.lv.study.am.first;

import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

//我们现在需要将一个对象发送给客户端;
public class DemoListServer {

    public static void main(String[] args) throws Exception {

        
        Goods goods1 = new Goods(1, "appler");
        Goods goods2 = new Goods(2, "pen");
        //需要将goods对象,发送给客户端;
        
        List<Goods> list = new ArrayList<Goods>();
        list.add(goods1);
        list.add(goods2);
        
        
        //当有客户端连接我的服务端的时候,
        //我发送我的商品信息给对方;
        
        //1:构建一个ServerSocket对象;等待客户端连接
        ServerSocket ss = new ServerSocket(8888);
        
        System.out.println("start ... watting...");
        
        //2: 来了连接以后,需要发送一个对象给对方;
        Socket server = ss.accept();
        
        //3:发送对象;使用输出流发送对象;
        OutputStream os = server.getOutputStream();
        
        //4:发送对象使用ObjectOutputStream
        ObjectOutputStream oos = new ObjectOutputStream(os);
        
        //一定要注意: 发送的对象,一定是可序列化的对象;  能够通过流在网络世界穿梭的对象;
        
        oos.writeObject(list);
        oos.flush(); //谁输出的,flush谁
        
        System.out.println("send object success....");
        
//        os.flush();//没用的
        server.close();
    }

}

客户端：

package com.lv.study.am.first;

import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.Socket;
import java.util.List;

public class DemoListClient {

    static String ip = "127.0.0.1";
    static int port = 8888;
    
    public static void main(String[] args) throws Exception {

        //1:首先要根据ip和端口建立一个socket
        
        Socket client = new Socket(ip,port);
        
        System.out.println("connection server...");
        
        //2:接受服务端发送给我的对象;
        InputStream is = client.getInputStream();
        
        //is能够接受一个对象吗?使用对象字节流来读取一个对象;
        ObjectInputStream ois = new ObjectInputStream(is);
        
        //读取了一个对象
        Object goods1 = ois.readObject();
        
        List<Goods> list = (List)goods1;
        
        System.out.println(goods1);
        
        client.close();
    }

}

注：Goods实体类里面一定要实现​  implements Serializable(序列化的接口)

2：Socket之 PrintWriter 与 Scanner应用 ; 专门用来处理字符串信息

　　PrintWriter : 高级输出流，Scanner : 高级输入流

package com.lv.study.pm.first;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class TestScanner {

    public static void main(String[] args) throws Exception {

        //给一个普通的输入流
        
        Socket socket=new Socket();
        
        Scanner scan1=new Scanner(System.in);//用作键盘录入
        
        Scanner scan2=new Scanner(new File("x.txt"));//用作文件读取
        
        Scanner scan3=new Scanner(socket.getInputStream());//用作网络通信里面的流
        
        scan1.nextLine();//读取键盘录入的信息
        scan2.nextLine();//读取文件里面的信息
        scan3.nextLine();//读取socket流里面的信息（客服端或者服务器端）法来的
        
        PrintWriter pw1=new PrintWriter(System.out);
        PrintWriter pw2=new PrintWriter("a.txt");
        PrintWriter pw3=new PrintWriter(socket.getOutputStream());
        
        
        pw1.println("控制台打印");pw1.flush();
        pw1.println("写在文件里面");pw2.flush();
        pw1.println("发给服务器或者客服端");pw3.flush();
        
        
    }

}

3：Socket 之 登录注册

　　服务器端：

package com.lv.study.pm.second;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class LoginServerMain {

    public static void main(String[] args) {

        try {
            // 构建一个ServerSocket对象
            ServerSocket ss = new ServerSocket(8888);

            // 无线连接客服端
            Socket server;

            Scanner scan;
            PrintWriter pw;
            System.out.println("start  i am server....");
            while (true) {
                server = ss.accept();// 只能监听一次

                System.out.println("client:" + server.getInetAddress().getHostAddress() + "connettion");

                scan = new Scanner(server.getInputStream());
                pw = new PrintWriter(server.getOutputStream());

                while (true) {
                    // 让客户来选择要这行的功能
                    String msg = "请选择你要执行的功能：1：登录  2：注册  3：其他";
                    pw.println(msg);// 发送给客服端
                    pw.flush();

                    // 接收客服的选择
                    String choose = scan.nextLine();

                    switch (choose) {
                    case "1":
                        Login(scan, pw);// 执行登录功能
                        break;
                    case "2":
                        regist(scan, pw);// 执行注册功能
                        break;

                    default:
                        // 向客户端发送一条信息
                        pw.println("系统正在升级中.......");
                        pw.flush();
                        break;
                    }
                }

            }

        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    private static void regist(Scanner scan, PrintWriter pw) {

        // 向客服端获取这个信息
        pw.println("---------欢迎使用ABC注册功能---------");
        pw.println("请输入用户名");
        pw.flush();

        // 接受客服端输入的用户名
        String name = scan.nextLine();

        // 发送给客服端
        pw.println("请输入密码");
        pw.flush();

        // 从客户端接受密码
        String pass1 = scan.nextLine();

        pw.println("请再次输入密码");
        pw.flush();
        String pass2 = scan.nextLine();

        pw.println("注册成功");
        pw.flush();

    }

    private static void Login(Scanner scan, PrintWriter pw) {

        //写信息到客服端
        pw.println("-------欢迎使用ABC登录功能------
 请输入用户名");pw.flush();
        
        //读取客户端的信息
        String name=scan.nextLine();
        
        pw.println("------请输入密码--------");pw.flush();
        
        String pass=scan.nextLine();
        
        pw.println("登录成功");
        System.out.println(name+":"+ pass);
    }

}

　　客户端：

package com.lv.study.pm.second;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class LoginClientMain {

    public static void main(String[] args) {

        String ip = "";
        int port = 8888;

        // 客服端，能够登陆注册

        try {
            Socket client = new Socket(ip, port);

            // 用来读取服务端发给我的信息
            Scanner scan = new Scanner(client.getInputStream());

            // 用来向服务端发送消息
            PrintWriter pw = new PrintWriter(client.getOutputStream());

            // 进行注册登陆的动作

            while (true) {// 能够循环的接受服务器发给我饿消息，以及一直给服务器发送这个指令
                // 1 接收服务端发给我的信息
                String msg = scan.nextLine();
                System.out.println(msg);

                // 2 向服务器发送信息

                // br:负责从键盘录入信息
                BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
                String clmsg = br.readLine();

                pw.println(clmsg);// 这个地方发送的消息是键盘录入的
                pw.flush();
            }

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

　　成果：