TCPSocket如何使用

这篇文章主要讲解了“TCP Socket如何使用”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“TCP Socket如何使用”吧！

成都创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都网站设计、做网站、保康网络推广、小程序制作、保康网络营销、保康企业策划、保康品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；成都创新互联为所有大学生创业者提供保康建站搭建服务，24小时服务热线：13518219792，官方网址：www.cdcxhl.com

Java为TCP协议提供了两个类，分别在客户端编程和服务器端编程中使用它们。在应用程序开始通信之前，需要先创建一个连接，由客户端程序发起；而服务器端的程序需要一直监听着主机的特定端口号，等待客户端的连接。在客户端中我们只需要使用Socket实例，而服务端要同时处理ServerSocket实例和Socket实例;二者并且都使用OutputStream和InpuStream来发送和接收数据。

学习一种知识***的方式就是使用它，通过前面的笔记，我们已经知道如何获取主机的地址信息，现在我们通过一个简单的程序来初步学习传输层使用了TCP协议的Socket编程。

TCP服务器端

在Socket编程中，服务器端远比客户端要复杂得多。服务器端的工作就是建立一个通信终端，被动的等待客户端的连接。下面这个服务器端程序的示例的作用是：监听从控制台输入获取的端口号，并且将客户端发送过来的消息，再发送回去。

import java.net.*;   import java.text.MessageFormat;   import java.io.*;      public class TCPEchoServer {          private static final int BUFSIZE = 32;          /**        * @param args    */      public static void main(String[] args) throws IOException {           // TODO Auto-generated method stub    // 从控制台获取需要监听的端口号           if (args.length != 1)               throw new IllegalArgumentException("Parameter(s):");           // 获取端口号           int servPort = Integer.parseInt(args[0]);           // 实例化一个ServerSocket对象实例           ServerSocket servSocket = new ServerSocket(servPort);           System.out.println(MessageFormat.format("开始启动监听，端口号:{0}", args[0]));              // 初始接收数据的总字节数           int recvMsgSize;           // 接收数据的缓冲区           byte[] receiveBuf = new byte[BUFSIZE];              // 循环迭代，监听端口号,处理新的连接请求           while (true) {               // 阻塞等待，每接收到一个请求就创建一个新的连接实例               Socket clntSocket = servSocket.accept();               // 获取连接的客户端的 SocketAddress               SocketAddress clientAddress = clntSocket.getRemoteSocketAddress();               // 打印输出连接客户端地址信息               System.out.println("Handling client at" + clientAddress);               // 从客户端接收数据的对象               InputStream in = clntSocket.getInputStream();               // 向客户端发送数据的对象               OutputStream out = clntSocket.getOutputStream();               // 读取客户端发送的数据后，再发送到客户端               while ((recvMsgSize = in.read(receiveBuf)) != -1) {                   out.write(receiveBuf, 0, recvMsgSize);               }               // 客户端关闭连接时，关闭连接               System.out.println(" 客户端关闭连接");               clntSocket.close();           }          }      }

TCP客户端

在Socket编程中，首先客户端需要向服务器端发送，然后被动的等待服务器端的响应。下面的示例中：我们向服务器端发送信息，等待服务器端发送的消息，并打印显示出来。

import java.io.*;   import java.net.Socket;   import java.net.SocketException;      public class TCPEchoClient {          /**        * @param args        * @throws IOException     */      public static void main(String[] args) throws IOException {           // TODO Auto-generated method stub    // 判断从控制台接受的参数是否正确           if ((args.length < 2) || (args.length > 3))               throw new IllegalArgumentException(                       "Parameter(s):[]]");           // 获取服务器地址           String server = args[0];           // 获取需要发送的信息           byte[] data = args[1].getBytes();           // 如果有三个从参数那么就获取发送信息的端口号，默认端口号为8099           int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099;           // 根据服务器地址和端口号实例化一个Socket实例           Socket socket = new Socket(server, servPort);           System.out.println("Connected to server...sending echo string");           // 返回此套接字的输入流，即从服务器接受的数据对象           InputStream in = socket.getInputStream();           // 返回此套接字的输出流，即向服务器发送的数据对象           OutputStream out = socket.getOutputStream();           // 向服务器发送从控制台接收的数据           out.write(data);           // 接收数据的计数器，将写入数据的初始偏移量           int totalBytesRcvd = 0;           // 初始化接收数据的总字节数           int bytesRcvd;           while (totalBytesRcvd < data.length) {               // 服务器关闭连接，则返回 -1,read方法返回接收数据的总字节数               if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length                       - totalBytesRcvd)) == -1)                   throw new SocketException("与服务器的连接已关闭");               totalBytesRcvd += bytesRcvd;           }           // 打印服务器发送来的数据           System.out.println("Received:" + new String(data));           // 关闭连接           socket.close();          }      }

首先运行服务器端,监听8099端口：

TCP Socket如何使用