Java中网络编程的学习

/*
客户端*/
public class Client {public static void main(String[] args) {//创建客户端try {Socket socket=new Socket("127.0.0.1",6666);//连接自己ip为127.0.0.1String s ="你好服务器";OutputStream output=socket.getOutputStream();output.write(s.getBytes());} catch (IOException e) {throw new RuntimeException(e);}}
}

使用包装流输入输出：

public class Client {public static void main(String[] args) {try {Socket socket = new Socket("127.0.0.1",6666);String s = "你好服务器";DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());dataOutputStream.writeUTF(s);DataInputStream dataInputStream  = new DataInputStream(socket.getInputStream());String s1 = dataInputStream.readUTF();System.out.println(s1);} catch (IOException e) {e.printStackTrace();}}
}

服务器程序的工作过程包含以下四个基本的步骤：

1.调用 ServerSocket(int port) ：

      创建一个服务器端套接字，并绑定到指定端口上。用于监听客户端的请求。

2.调用 accept()：

     监听连接请求，如果客户端请求连接，则接受连接，返回通信套接字对象。

3.调用 该Socket类对象的 getOutputStream() 和 getInputStream ()：

     获取输出流和输入流，开始网络数据的发送和接收。

4.关闭ServerSocket和Socket对象：

     客户端访问结束，关闭通信套接字。

服务器建立 ServerSocket 对象

      ServerSocket 对象负责等待客户端请求建立套接字连接，类似邮局某个窗口中的业务员。也就是说，服务器必须事先建立一个等待客户请求建立套接字连接的ServerSocket对象。

/*
服务器*/
public class Server {public static void main(String[] args) {try {//创建服务器对象ServerSocket serverSocket=new ServerSocket(6666);System.out.println("服务器启动成功");//监听客户端是否向服务器发送链接请求Socket socket= serverSocket.accept();System.out.println("有客户端连接到了服务器");//后续操作InputStream input=socket.getInputStream();byte[]bytes=new byte[100];int size=input.read(bytes);String s=new String(bytes,0,size);System.out.println(s);}catch (IOException e){e.printStackTrace();System.out.println("服务器启动失败，端口已被占用");}}
}

使用包装流输入输出：

public class Server {public static void main(String[] args) {try {System.out.println("服务器开始启动");ServerSocket serverSocket =   new ServerSocket(6666);System.out.println("服务器启动成功");Socket socket = serverSocket.accept();//包装流 直接读到一个字符串DataInputStream dataInputStream = new DataInputStream(socket.getInputStream());String s = dataInputStream.readUTF();System.out.println(s);//从服务器端向客户端发送一个消息String s1 = "你好客户端!";DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());dataOutputStream.writeUTF(s1);} catch (IOException e) {e.printStackTrace();}}
}

UDP编程

    类 DatagramSocket 和 DatagramPacket 实现了基于 UDP 协议网络程序。

    UDP数据报通过数据报套接字 DatagramSocket 发送和接收，系统不保证UDP数据报一定能够安全送到目的地，也不能确定什么时候可以抵达。

     DatagramPacket 对象封装了UDP数据报，在数据报中包含了发送端的IP地址和端口号以及接收端的IP地址和端口号。

     UDP协议中每个数据报都给出了完整的地址信息，因此无须建立发送方和接收方的连接

流程：

1. DatagramSocket与DatagramPacket

2. 建立发送端，接收端

3. 建立数据报

4. 调用Socket的发送、接收方法

5. 关闭Socket

注意：发送端与接收端是两个独立的运行程序

发送端

/*
发送端*/
public class Send {public static void main(String[] args) throws IOException {//用来发送和接受数据DatagramSocket datagramSocket=new DatagramSocket();
/*public DatagramPacket(byte buf[], int offset, int length,InetAddress address, int port) {  参数分别为字节数组，从哪里开始发送 ，发送多长 ，用一个类来分装IP地址，端口setData(buf, offset, length);setAddress(address);setPort(port);}*/byte []bytes="你好".getBytes();//数据报DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length, InetAddress.getByName("127.0.0.1"),6666);//发送datagramSocket.send(datagramPacket);System.out.println("发送完成");}
}

接收端，要指定监听的端口

/*
接收端*/
public class Receive {public static void main(String[] args) throws IOException {//用来发送和接受数据DatagramSocket datagramSocket=new DatagramSocket(6666);//创建一个接受的数据报byte[]bytes=new byte[100];DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length);//接受datagramSocket.receive(datagramPacket);String s=new String(bytes,0,datagramPacket.getLength());//datagramPacket.getLength()接受到数据的实际长度}
}