基于TCP协议的Socket编程

1.单向通信实现

传输示意图

客户端程序

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 clinet {
    
    public static void main(String[] args) throws IOException {
        //创建Socket对象
        Socket clinet = new Socket("127.0.0.1",9999);
        //获取输出流
        DataOutputStream dos = new DataOutputStream(clinet.getOutputStream());
        dos.writeUTF("hello word!");
        //获取输入流
        DataInputStream dis = new DataInputStream(clinet.getInputStream());
        System.out.println(dis.readUTF());
        //关闭流
        if(dis != null) {
            dis.close();
        }
        if(dos != null) {
            dos.close();
        }
        if(clinet != null) {
            clinet.close();
        }
    }
}

服务器程序

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

public class Server {

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

}

先启动服务器，再启动客户端

服务器：

客户端：

 

 

 

 

2.模拟用户登陆

服务器

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

import javax.swing.plaf.synth.SynthSeparatorUI;

import org.omg.PortableInterceptor.DISCARDING;

public class Server2 {

    public static void main(String[] args) throws IOException, ClassNotFoundException {
        System.out.println("------服务器端已启动----------");
        //创建ServerSocket对象
        ServerSocket server = new ServerSocket(10000);
        Socket socket = server.accept();
        //获取输入流（对象流）
        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        //对用户名和密码进行验证
        User user = (User)ois.readObject();
        System.out.println(socket.getInetAddress().getHostAddress()+"请求登陆：用户名"+user.getUsername()+"	密码："+user.getPassword());
        String str = "";
        if("chb".equals(user.getUsername())&&"123456".equals(user.getPassword())) {
            str = "登陆成功";
        }else {
            str = "登陆失败";
        }
        //获取输出流（数据流）
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        dos.writeUTF(str);
        //关闭流
        if(dos != null) {
            dos.close();
        }
        if(ois != null) {
            ois.close();
        }
        socket.close();
    }

}

客户端

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

public class Clint2 {
    
    public static void main(String[] args) throws IOException {
        //(1)创建Socket对象，用于连接服务器
        Socket clint = new Socket("localhost", 10000);
        //(2)获取输出流（对象流）
        ObjectOutputStream oos = new ObjectOutputStream(clint.getOutputStream());
        //(3)创建User对象
        User user = getUser();
        //(4)User对象发生到服务器
        oos.writeObject(user);
        //(5)获取输入流（数据流）
        DataInputStream dis = new DataInputStream(clint.getInputStream());
        System.out.println(dis.readUTF());
        if(dis != null) {
            dis.close();
        }
        if(oos != null) {
            oos.close();
        }
        clint.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);
    }
}

3.UDP 通信_DatagramSocket 实现_客户咨询

1) 不需要利用 IO 流实现数据的传输

2) 每个数据发送单元被统一封装成数据包的方式，发送方将数据包发送到网络中，数据包在网络中去寻找他的目的地。

3) DatagramSocket：用于发送或接收数据包

4) DatagramPacket：数据包

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Test1 {
    //接收方
            /** 一收，
             * 一发
             * @throws IOException 
             */
    public static void main(String[] args) throws IOException {
        System.out.println("客服人员");
        DatagramSocket ds=new DatagramSocket(9999);
        //准 备接收数据
        byte [] buf=new byte[1024];
        //准 备数据报接收
        DatagramPacket dp=new DatagramPacket(buf, buf.length);
        
        //接收
        ds.receive(dp);
        
        //查看接收到的数据
        String str=new String(dp.getData(),0,dp.getLength());
        System.out.println("客户说:"+str);
        
        
        /**回复数据*/
        byte [] buf2="welcome to beijing".getBytes();//发生的内容 长度  地址 端口号
        DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
        ds.send(dp2);
        //关闭
        ds.close();
        
            
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.util.Scanner;

public class Test2 {
    //
            /** 一收，
             * 一发
             * @throws IOException 
             */
    public static void main(String[] args) throws IOException {
        Scanner input=new Scanner(System.in);
        System.out.println("客服人员");
        DatagramSocket ds=new DatagramSocket(9999);
        while(true){
            //准 备接收数据
            byte [] buf=new byte[1024];
            //准 备数据报接收
            DatagramPacket dp=new DatagramPacket(buf, buf.length);
            
            //接收
            ds.receive(dp);
            
            //查看接收到的数据
            String str=new String(dp.getData(),0,dp.getLength());
            System.out.println("客户说:"+str);
            
            String s=input.next();
            /**回复数据*/
            byte [] buf2=s.getBytes();
            DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
            ds.send(dp2);
            if("bye".equals(s)){
                break;
            }
        }
        //关闭
            
        ds.close();
        
            
    }
}