网路编程

UDP
将数据源和目的封装成数据包中，不需要建立连接；
每个数据报包的大小在限制在64k；因无连接，是不可靠协议；不需要建立连接，速度快

UDP传输发送端思路

1:建立udp的socket服务
2:将要发送的数据封装成数据包
3:通过udp的socket服务,将数据包发送出
4:关闭资源

点击查看代码

public class SendDemo1 {public static void main(String[] args) throws Exception {// 1:建立udp的socket服务// DatagramSocket//DatagramSocket()//构造数据报套接字并将其绑定到本地主机上的任何可用端口。
//        1:建立udp的socket服务DatagramSocket socket = new DatagramSocket();
//      2:将要发送的数据封装成数据包 DatagramPacket//DatagramPacket(byte[] buf, int length, InetAddress address, int port)//构造用于发送长度的分组的数据报包 length指定主机上到指定的端口号。byte[] bytes = "他见到我，跑着过来了".getBytes();int length = bytes.length;InetAddress address = InetAddress.getByName("192.168.22.25");DatagramPacket packet = new DatagramPacket(bytes, length, address, 10086);//10086是自己给定的端口号// 3:通过udp的socket服务,将数据包发送出//public void send(DatagramPacket p)socket.send(packet);//    4:关闭资源socket.close();}
}

UDP传输接收端思路

   1:建立udp的socket服务.2:通过receive方法接收数据3:将收到的数据存储到数据包对象中4:通过数据包对象的功能来完成对接收到数据进行解析.5:可以对资源进行关闭

点击查看代码

public class ReceiveDemo1 {public static void main(String[] args) throws Exception {
//        1:建立udp的socket服务.//DatagramSocket socket = new DatagramSocket(10086);//发送端和接收端的端口号要保持一致
//        2:通过receive方法接收数据
//        3:将收到的数据存储到数据包对象中byte[] bytes = new byte[1024];DatagramPacket packet = new DatagramPacket(bytes, bytes.length);socket.receive(packet);
//        4:通过数据包对象的功能来完成对接收到数据进行解析byte[] data = packet.getData();int length = packet.getLength();String s = new String(data, 0, length);System.out.println("收到的数据：" + s);}
}

InetAddress: java提供的类，用于表示ip地址

点击查看代码

public class InetAddressDemo1 {public static void main(String[] args) throws  Exception{// static InetAddress getLocalHost()//返回本地主机的地址。InetAddress ip1 = InetAddress.getLocalHost();System.out.println(ip1);// String getHostName()//获取此IP地址的主机名。String hostName = ip1.getHostName();//String getHostAddress()//获取此IP地址String address = ip1.getHostAddress();System.out.println("主机名:"+hostName+",ip地址："+ address);}
}

实现聊天室

发送端

点击查看代码

public class SendDemo1 {public static void main(String[] args) throws Exception{
//    1:建立udp的socket服务DatagramSocket socket = new DatagramSocket();Scanner sc = new Scanner(System.in);
while(true){//    2:将要发送的数据封装成数据包System.out.println("请输入发送内容：");String data = sc.nextLine();byte[] bytes = data.getBytes();int length = bytes.length;InetAddress address = InetAddress.getByName("192.168.22.25");DatagramPacket packet = new DatagramPacket(bytes, length, address, 10000);//    3:通过udp的socket服务,将数据包发送出socket.send(packet);if("886".equals(data)){System.out.println("用户已经离开");break;}}//    4:关闭资源
socket.close();}
}

接收端

点击查看代码

public class ReceiveDemo1 {public static void main(String[] args) throws Exception{
//        1:建立udp的socket服务.DatagramSocket socket = new DatagramSocket(10000);
//        2:通过receive方法接收数据
//        3:将收到的数据存储到数据包对象中System.out.println("==============欢迎来到聊天室=================");while(true){byte[] bytes = new byte[1024];int length = bytes.length;DatagramPacket packet = new DatagramPacket(bytes, length);socket.receive(packet);
//        4:通过数据包对象的功能来完成对接收到数据进行解析.byte[] data = packet.getData();int length1 = packet.getLength();String s = new String(data, 0, length1);InetAddress address = packet.getAddress();String hostName = address.getHostName();BufferedWriter bw = new BufferedWriter(new FileWriter("src/com/shujia/day19/recode/" + hostName + ".txt",true));//将用户的聊天内容打包写入if("886".equals(s)){System.out.println("=====================");System.out.println("用户已经下线");System.out.println("=====================");}else{String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss a").format(new Date());System.out.println(time);System.out.println(hostName+":"+s);bw.write(time);bw.newLine();bw.write(s);bw.newLine();bw.flush();}
}}
}

TCP建立连接，形成传输数据的通道；在连接中进行大数据量传输；
通过三次握手完成连接，是可靠协议；必须建立连接，效率会稍低

TCP传输

    1:建立客户端的Socket服务,并明确要连接的服务器。2:如果连接建立成功,就表明,已经建立了数据传输的通道.就可以在该通道通过IO进行数据的读取和写入.该通道称为Socket流,Socket流中既有读取流,也有写入流.3:通过Socket对象的方法,可以获取这两个流4:通过流的对象可以对数据进行传输5:如果传输数据完毕,关闭资源

TCP传输-客户端代码

    1:建立客户端的Socket服务,并明确要连接的服务器。2:如果连接建立成功,就表明,已经建立了数据传输的通道.就可以在该通道通过IO进行数据的读取和写入.该通道称为Socket流,Socket流中既有读取流,也有写入流.3:通过Socket对象+的方法,可以获取这两个流4:通过流的对象可以对数据进行传输5:如果传输数据完毕,关闭资源

点击查看代码

public class ClientDemo1 {public static void main(String[] args) throws Exception{// 1:建立客户端的Socket服务,并明确要连接的服务器。//Socket(String host, int port)//创建流套接字并将其连接到指定主机上的指定端口号。Socket socket = new Socket("192.168.22.15", 12345);Scanner sc = new Scanner(System.in);// 3:通过Socket对象的方法,可以获取这两个流//获取通道中的输出流，将数据发送给服务端OutputStream outputStream = socket.getOutputStream();//获取通道中的输入流InputStream inputStream = socket.getInputStream();while (true){System.out.print("请输入要发送的内容：");String info = sc.nextLine();if("886".equals(info)){break;}// 4:通过流的对象可以对数据进行传输outputStream.write(info.getBytes());outputStream.flush(); // 来自于通道中的类byte[] bytes = new byte[1024];int length = inputStream.read(bytes);String s = new String(bytes, 0, length);System.out.println(s);}// 5:如果传输数据完毕,关闭资源
//        outputStream.close();socket.close();}
}

TCP传输-服务器端代码

    1:建立服务器端的socket服务，需要一个端口2:服务端没有直接流的操作,而是通过accept方法获取客户端对象，在通过获取到的客户端对象的流和客户端进行通信3:通过客户端的获取流对象的方法,读取数据或者写入数据4:如果服务完成,需要关闭客户端,然后关闭服务器，但是,一般会关闭客户端,不会关闭服务器,因为服务端是一直提供服务的

点击查看代码

public class ServerDemo1 {public static void main(String[] args){try {// 1:建立服务器端的socket服务，需要一个端口//ServerSocket(int port)//创建绑定到指定端口的服务器套接字。ServerSocket ss = new ServerSocket(12345);// 2:服务端没有直接流的操作,而是通过accept方法获取客户端对象，在通过获取到的客户端对象的流和客户端进行通信Socket socket = ss.accept();while (true){InetAddress inetAddress = socket.getInetAddress();String hostName = inetAddress.getHostName();// 3:通过客户端的获取流对象的方法,读取数据或者写入数据// 获取通道中的输入流InputStream inputStream = socket.getInputStream();byte[] bytes = new byte[1024];int length = inputStream.read(bytes);String s = new String(bytes, 0, length);System.out.println(hostName+": "+s);// 获取通道中的输出流OutputStream outputStream = socket.getOutputStream();outputStream.write("服务器已接收！".getBytes());outputStream.flush();}}catch (Exception e){System.out.println("用户已退出。。。");}}
}