java.net
类 InetAddress
 
java.lang.Object
-> java.net.InetAddress
 
已实现的接口: Serializable
已知子类: Inet4Address, Inet6Address
 
public class InetAddress extends Object implements Serializable
该类表示互联网协议ip地址

java.net
类 Inet6Address
 
java.lang.Object
-> java.net.InetAddress
-> java.net.Inet6Address
 
所有已实现的接口:Serializable
 
public final class Inet6Address extends InetAddress
该类表示互联网协议第6版地址

// hosts 文件配置
127.0.0.1 www.###.cn // 该域名地址

java.net
Class DatagramPacket
java.lang.Object
-> java.net.DatagramPacket
 
public final class DatagramPacket extends Object
该类表示数据报包
 
将数据封装到数据包中,数据包对象为DatagramPacket

DatagramPacket(byte[] buf, int length)
// 字节数组来的

receive
public void receive(DatagramPacket p) throws IOException
此套接字接收数据报包
返回, DatagramPacket的缓冲区填充了接收的数据
数据报包也包含发送的ip地址和发送方的端口号

package com.dashucoding.udp;
 
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
 
public class UDPRece {
 
   public static void main(String[] args) throws IOException {
       System.out.println("udp 接收端 run");
       // 定义udp接收数据,显示在屏幕上
       // 先有插座嘛,udpsocket服务
       // 接收数据前 -> 先将数据存储到数据包中
       // 先定义数据包
       // 数据包对象会获取数据包中的内容,发送端的ip和端口
       // 关闭资源
 
       // 有upsocket服务
       DatagramSocket ds = new DatagramSocket(10000);
       // 接收数据,接收字节数据
       byte[] buf = new byte[1024];
       // 定义包
       DatagramPacket dp = new DatagramPacket(buf, buf.length);
 
       // 还没存到数据包,进行存储
       ds.receive(dp); // 阻塞
 
       String ip = dp.getAddress().getHostAddress();
       int port = dp.getPort();
       String text = new String(dp.getData(),0,dp.getLength());
 
       System.out.println(ip+" : "+port+" : "+text);
       // 关闭资源
       ds.close();
 
   }
 
}

键盘录入
 
发送端:

package com.dashucoding.udp2;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
 
public class UDPSend2 {
 
   public static void main(String[] args) throws IOException {
       // TODO Auto-generated method stub
       System.out.println("udp2 发送端 run");
       DatagramSocket ds = new DatagramSocket();
       // 数据来源于键盘录入
       BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
       String line = null;
       while ((line = bufr.readLine()) != null) {
           if("over".equals(line)) {
               break;
           }
           // 将数据转成字节数组
           byte[] buf = line.getBytes();
           // 将字节数据封装到数据包中
           DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("你的ip地址"), 10002);
           ds.send(dp);
           // 发完关掉,不然留着资源干嘛
       }
 
       ds.close();
   }
 
}

package com.dashucoding.udp2;
 
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
 
public class UDPRece2 {
 
   public static void main(String[] args) throws IOException {
       // 有upsocket服务
       System.out.println("udp2 接收端 run");
       DatagramSocket ds = new DatagramSocket(10002);
       while (true) {
 
           // 接收数据,接收字节数据
           byte[] buf = new byte[1024];
           // 定义包
           DatagramPacket dp = new DatagramPacket(buf, buf.length);
 
           // 还没存到数据包,进行存储
           ds.receive(dp); // 阻塞
 
           String ip = dp.getAddress().getHostAddress();
           int port = dp.getPort();
           String text = new String(dp.getData(), 0, dp.getLength());
 
           System.out.println(ip + " : " + port + " : " + text);
           // 关闭资源
       }
       // ds.close();
   }
}

Socket()
通过系统默认类型的SocketImpl创建未连接套接字
 
Socket(InetAddress address, int port)
创建一个流套接字并将其连接到指定ip地址的指定端口
 
Socket(String host, int port)
创建一个流套接字并将其连接到指定主机上的指定端口号
 
getOutputStream()
 
返回此套接字的输出流

package com.dashucoding.tcp;
 
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class TCPClient {
 
   public static void main(String[] args) throws UnknownHostException, IOException {
       // TODO Auto-generated method stub
       // 建立tcp的客户端socket 明确服务端的地址和端口
       // socket io流
       // 获取socket流
 
       System.out.println("客户端运行");
       // 建立tcp的客户端socket,明确服务端的地址和端口
       Socket s = new Socket("ip地址",20003);
       // socket输出流数据发送
       OutputStream out = s.getOutputStream();
       // 通过socket输出流将数据发送
       out.write("hello tcp 来了".getBytes());
       // 关闭
       s.close();
   }
 
}

package com.dashucoding.tcp;
 
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
 
public class TCPServer {
 
   public static void main(String[] args) throws IOException {
       // TODO Auto-generated method stub
       // 获取客户端的数据,在屏幕上
 
       // 思路
       // 创建服务端的socket,明确端口,监听一个端口
       // 服务端只要获取到链接过来的客户端就可以和指定的客户端通信了
       // 通过获取客户端的读取流对象读取客户端发来的数据.
       // 显示屏幕上
       System.out.println("服务端运行");
 
       // 创建服务端的socket,明确接收端口
       ServerSocket ss = new ServerSocket(20003);
 
       while (true) {
           // 服务端只要获取到连接过来的客户端就可以和指定的客户端通信
           Socket s = ss.accept();
           String ip = s.getInetAddress().getHostAddress();
           System.out.println(ip + "...connected");
 
           // 通过获取客户端的读取流对象读取客户端发送来的数据
           InputStream in = s.getInputStream();
           // 流操作
           byte[] buf = new byte[1024];
           int len = in.read(buf);
           String text = new String(buf, 0, len);
           System.out.println(text);
           // 关闭
           s.close();
       }
       // ss.close();
   }
 
}