00023.08 Socket概述、TCP协议编程：一来一回

Socket概述目录

一、Socket概述

不管传输层使用的是TCP/UDP协议，Java中用这样的API来表示，Socket（套接字）

分类：

（1）流套接字：用于TCP，ServerSocket类和Socket类

（2）数据报套接字：用于UDP，DatagramSocket类

Socket（也可以叫“套接字”），是两台机器间通信的端点。可以和网卡驱动进行交流。负责把数据交给网卡驱动，或者从网卡驱动中提取数据。

二、TCP协议编程：一来一回

然后进行改造：

需求

客户端说一句你好

服务端回复一句，欢迎你登录开始改造：

客户端

下面一个while是必须的，发过去同时也要一直接收

服务端也要一直接收

怎么运行看效果

上面这个问题要怎么解决呢？

这样就可以了

但是这样有一个很严重的问题，就是你只能发一次，后面再也不能发了
如果我们还想继续发数据进行很多次交流怎么解决呢？
下一篇文章继续这一块的疑问进行解答

总结

1、Socket的作用：Socket（也可以叫“套接字”），是两台机器间通信的端点。可以和网卡驱动进行交流。负责把数据交给网卡驱动，或者从网卡驱动中提取数据
2、简单了解一下客户端与服务器互发消息

1、完整代码：模板

TestServer：

package com.atguigu.test10;

import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/*
 * TCP：面向连接，可靠的，基于字节流的
 *    服务器：等待被连接的过程
 * 
 * ServerSocket：只负责接受和建立连接，不负责数据的传输
 * Socket：负责数据的传输
 * 
 * 步骤：
 * 1、开启服务器
 *    指定服务器监听的端口号
 * 2、等待客户端并接受客户端的连接
 * 
 * 3、接受/发送数据
 * 发送方：输出流
 * 接受方：输入流
 * 
 * 4、断开连接
 * 
 * 5、关闭服务器
 */
public class TestServer {
  public static void main(String[] args) throws IOException {
    //1、开启服务器：网卡驱动就监听9999端口号的数据
    ServerSocket server = new ServerSocket(9999);
    
    //2、等待客户端并接受客户端的连接
    Socket socket = server.accept();//这句代码执行一次，就接受一个客户端连接
    System.out.println("一个客户端连接成功!");
    //3、例如：发送数据
    //发送：欢迎你登录
    //字节流，输出流  OutputStream
    //(1)获取输出流
    OutputStream out = socket.getOutputStream();
    //(2)发送数据
    out.write("欢迎你登录".getBytes());
    
    //4、断开连接
    socket.close();
    
    //5、关闭服务器
    server.close();
  }
}

TestClient：

package com.atguigu.test10;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.net.UnknownHostException;

/*
 * TCP：
 *   客户端，主动连接服务器
 * 
 * Socket(InetAddress address, int port) 
 * Socket(String host, int port)
 * 
 * 步骤：
 * 1、连接服务器
 * Socket socket = new Socket("192.168.30.142",9999);
 * 
 * 2、发送或接受数据
 * 
 * 3、断开连接
 */
public class TestClient {
  public static void main(String[] args) throws UnknownHostException, IOException {
//    1、连接服务器
    Socket socket = new Socket("192.168.30.142",9999);
    
    //2、例如：接受数据
    //字节流，输入流，InputStream
    InputStream in = socket.getInputStream();
    byte[] data = new byte[1024];
    int len;
    while((len = in.read(data)) != -1){
      System.out.println(new String(data,0,len));
    }
    
    //3、断开
    socket.close();
  }
}

2、TCP协议编程：一来一回：

TestServer：

package com.atguigu.test11;

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

/*
 * TCP：面向连接，可靠的，基于字节流的
 *    服务器：等待被连接的过程
 * 
 * ServerSocket：只负责接受和建立连接，不负责数据的传输
 * Socket：负责数据的传输
 * 
 * 步骤：
 * 1、开启服务器
 *    指定服务器监听的端口号
 * 2、等待客户端并接受客户端的连接
 * 
 * 3、接受/发送数据
 * 发送方：输出流
 * 接受方：输入流
 * 
 * 4、断开连接
 * 
 * 5、关闭服务器
 */
public class TestServer {
  public static void main(String[] args) throws IOException {
    //1、开启服务器：网卡驱动就监听9999端口号的数据
    ServerSocket server = new ServerSocket(9999);
    
    //2、等待客户端并接受客户端的连接
    Socket socket = server.accept();//这句代码执行一次，就接受一个客户端连接
    System.out.println("一个客户端连接成功!");
    
    //3、接受数据
    InputStream in = socket.getInputStream();
    byte[] data = new byte[1024];
    int len;
    System.out.println("服务器收到：");
    while((len = in.read(data)) != -1){
      System.out.println(new String(data,0,len));
    }
    
    //4、例如：发送数据
    //发送：欢迎你登录
    //字节流，输出流  OutputStream
    //(1)获取输出流
    OutputStream out = socket.getOutputStream();
    //(2)发送数据
    out.write("欢迎你登录".getBytes());
    
    //4、断开连接
    socket.close();
    
    //5、关闭服务器
    server.close();
  }
}

TestClient：

package com.atguigu.test11;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

/*
 * TCP：
 *   客户端，主动连接服务器
 * 
 * Socket(InetAddress address, int port) 
 * Socket(String host, int port)
 * 
 * 步骤：
 * 1、连接服务器
 * Socket socket = new Socket("192.168.30.142",9999);
 * 
 * 2、发送或接受数据
 * 
 * 3、断开连接
 * 
 * 客户端给服务器发送一个“你好”，服务器回复“欢迎你登录”
 */
public class TestClient {
  public static void main(String[] args) throws UnknownHostException, IOException {
//    1、连接服务器
    Socket socket = new Socket("192.168.30.142",9999);
    
    //2、例如：发送你好
    OutputStream out = socket.getOutputStream();
    out.write("你好".getBytes());
//    out.close();//错误的，如果调用out.close()会导致socket的close()
    //如果仅仅表示不发送了，还要接收，那么选择半关闭，只关闭输出通道
    socket.shutdownOutput();
    
    //3、例如：接受数据
    //字节流，输入流，InputStream
    System.out.println("客户端收到：");
    InputStream in = socket.getInputStream();
    byte[] data = new byte[1024];
    int len;
    while((len = in.read(data)) != -1){
      System.out.println(new String(data,0,len));
    }
    
    //3、断开
    socket.close();
  }
}