javaTCP通信之socket编程

TCP通信能实现两台计算机之间的数据交互&＃xff0c;通信的两端&＃xff0c;要严格区分为客户端&＃xff08;Client&＃xff09;与服务端&＃xff08;Server&＃xff09;。
两端通信时步骤&＃xff1a;

1. 服务端程序&＃xff0c;需要事先启动&＃xff0c;等待客户端的连接。
2. 客户端主动连接服务器端&＃xff0c;连接成功才能通信。服务端不可以主动连接客户端。
   在Java中&＃xff0c;提供了两个类用于实现TCP通信程序&＃xff1a;
   客户端&＃xff1a;java.net.Socket 类表示。创建Socket对象&＃xff0c;向服务端发出连接请求&＃xff0c;服务端响应请求&＃xff0c;两者建立连接开始通信。
   服务端&＃xff1a;java.net.ServerSocket 类表示。创建ServerSocket对象&＃xff0c;相当于开启一个服务&＃xff0c;并等待客户端的连接。
   构造方法
   public Socket(String host, int port) :创建套接字对象并将其连接到指定主机上的指定端口号。如果指定的host是null &＃xff0c;则相当于指定地址为回送地址。
   成员方法
   public InputStream getInputStream() &＃xff1a; 返回此套接字的输入流。
   如果此Scoket具有相关联的通道&＃xff0c;则生成的InputStream 的所有操作也关联该通道。
   关闭生成的InputStream也将关闭相关的Socket。

public OutputStream getOutputStream() &＃xff1a; 返回此套接字的输出流。
如果此Scoket具有相关联的通道&＃xff0c;则生成的OutputStream 的所有操作也关联该通道。
关闭生成的OutputStream也将关闭相关的Socket。

public void close()&＃96; &＃xff1a;关闭此套接字。
一旦一个socket被关闭&＃xff0c;它不可再使用。
关闭此socket也将关闭相关的InputStream和OutputStream 。

public void shutdownOutput() &＃xff1a; 禁用此套接字的输出流。

任何先前写出的数据将被发送&＃xff0c;随后终止输出流。

实现步骤
1.创建一个客户端socket&＃xff0c;构造方法绑定服务器端的ip地址和端口号
2.使用socket对象中的方法getOutputStream获取字节输出流OutputStream对象
3.使用网络字节输出流OutputStream对象中的方法write&＃xff0c;给服务器发送数据
4.使用socket对象中的方法getInputStream获取字节输入流InputStream对象
5.使用网络字节输出流InputStream对象中的方法read&＃xff0c;读取客户端的数据
6释放资源
注意
1.客户端和服务器端进行交互&＃xff0c;必须使用socket提供的网络流&＃xff0c;不能使用自己创建的流对象
2.当我们创建客户端对象socket时&＃xff0c;会请求服务器和服务器建立三次握手建立连接通道&＃xff0c;&＃xff08;如果服务器未启动那么就会抛出异常&＃xff0c;如果服务器已启动就可以进行交互&＃xff09;
ServerSocket类&＃xff1a;这个类实现了服务器套接字&＃xff0c;该对象等待通过网络的请求。

服务器端

TCP通信的服务器端&＃xff1a;接收客户端的请求&＃xff0c;读取客户端发送的数据&＃xff0c;给客户端回写数据

• public ServerSocket(int port) &＃xff1a;使用该构造方法在创建ServerSocket对象时&＃xff0c;就可以将其绑定到一个指定的端口号上&＃xff0c;参数port就是端口号。

构造举例&＃xff0c;代码如下&＃xff1a;

ServerSocket server &＃61; new ServerSocket(6666);


** 成员方法**

• public Socket accept() &＃xff1a;侦听并接受连接&＃xff0c;返回一个新的Socket对象&＃xff0c;用于和客户端实现通信。该方法会一直阻塞直到建立连接。
  服务器端必须明确是哪个客户端请求服务器&＃xff0c;可以使用accept方法获取获取请求的客户端对象socket
  成员方法&＃xff1a;
  Socket accept() 侦听并接收此套接字的连接
  步骤
  1、创建服务器ServerSocket和系统指定的端口号
  2、使用ServerSocket中的accept方法&＃xff0c;获取请求的客户端对象socket
  3、使用socket对象中的方法getInputStream获取字节输入流InputStream对象
  4、使用网络字节输出流InputStream对象中的方法read&＃xff0c;读取客户端的数据
  5.使用socket对象中的方法getOutputStream获取字节输出流OutputStream对象
  6.使用网络字节输出流OutputStream对象中的方法write&＃xff0c;给客户端发送数据
  7.关闭资源

服务器端

package com.blb.com;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 {
ServerSocket serverSocket&＃61;new ServerSocket(8888);Socket accept &＃61; serverSocket.accept();byte[] bytes&＃61;new byte[1024];int len&＃61;0;InputStream inputStream &＃61; accept.getInputStream();len&＃61;inputStream.read(bytes);String s &＃61; new String(bytes, 0, len);System.out.println(s);OutputStream outputStream &＃61; accept.getOutputStream();outputStream.write("你好客户端".getBytes());accept.close();serverSocket.close();}
}

客户端

package com.blb.com;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;public class Client {public static void main(String[] args) throws IOException {Socket socket&＃61;new Socket("127.0.0.1",8888);OutputStream outputStream &＃61; socket.getOutputStream();outputStream.write("你好服务器".getBytes());int len;byte[] bytes&＃61;new byte[1024];InputStream inputStream &＃61; socket.getInputStream();while ((len&＃61;inputStream.read(bytes))!&＃61;-1){String s&＃61;new String(bytes,0,len);System.out.println(s);}socket.close();}
}