socket建立tcp连接的java代码

Java-socket编程（建⽴连接）

socket编程是以IO为理论基础的，理论学得差不多也很难实现编程，毕竟⾥⾯的类和⽅法平时都不怎么⽤，难得尝试编了个程，记录⼀下。

1.⼏个概念

Channel：管道，连通客户端和服务端传输数据；

Buffer：缓冲区，通过管道传输数据必须经过的地⽅；

Selector：选择器，单线程可以通过选择器处理多个管道；本⽂没有使⽤；

2.案例功能

启动服务端，再启动客户端与服务端连接，在客户端的控制台输⼊命令获取服务端的效果。本样例只处理了“time”命令，获取服务端的当前

时间，其他命令都返回“⾮指定命令，⽆返回值”。详看代码注释。

3.服务端代码

1 import .InetSocketAddress;

2 import java.nio.ByteBuffer;

3 import java.nio.channels.ServerSocketChannel;

4 import java.nio.channels.SocketChannel;

5 import java.nio.charset.StandardCharsets;

6 import java.util.Date;

7 import java.util.LinkedList;

8

9 public class NIOService {

10 static int PORT = 9011;

11 public static void main(String[] args) throws Exception{

12 //存储客户端连接

13 LinkedList clients = new LinkedList<>();

14 //1.服务端开启监听：接受客户端

15 ServerSocketChannel ss = ServerSocketChannel.open();

16 ss.bind(new InetSocketAddress(PORT));

１９２　福建　电脑　２ｏｏ７年第１期　

通过Ｊａｖａ　Ｓｏｃｋｅｔ建立连接类实现与Ｗｅｂ服务器的交互操作　

曹大有，张斌　（郧阳师范高等专科学校计算机科学系湖北丹江口４４２７００）　【摘要】：在将数据发送到服务器，与服务器实现数据交互操作时，通常有ＧＥＴ方法和ＰＯＳＴ方法。本文通过Ｊａｖａ　Ｓｏｃｋｅｔ类建立一个实现ＰＯＳＴ方法的输出流类，通过此类我们可以实现与服务器的数据交互操作。　【关键词】：服务器浏览器Ｓｏｃｋｅｔ　ＧＥＴ　ＰＯＳＴ　在Ｊａｖａ技术问世之前．就有了用于编写交互式Ｗｅｂ应用程　序的机制。这时用户若要将数据从浏览器发送到服务器。用户必　须填写一个表单。当用户单击”Ｓｕｂｍｉｔ＂按钮时，表单中的数据将　发送给服务器，以便由ＣＧＩ脚本程序进行处理，而要使用的脚本　程序是在ＨＴＭＬ文件中由ＦＯＲＭ标记的ＡＣＴＩＯＮ属性中设定　的。　ＣＧＩ脚本程序是驻留在服务器计算机上的一个程序。一个　服务器上通常可以存在许多个脚本程序，它们通常驻留在ｃ　一　ｂｉｎ目录中。服务器调用ＣＧＩ脚本程序后，为它填人表单数据，然　后ＣＧＩ脚本程序对表单中的数据进行处理．并且产生另一个　ＨＴＭＬ页．由服务器将该页发回给浏览器。ＣＧＩ脚本程序通常是　用Ｐｅｒｌ语言编写的，不过它们也可以用任何一种能够进行标准　输入的读取和标准输出的写入的语言来编写。　ＣＧＩ是一个可以使用的好工具，因为它设计得很好，并且系　统管理员对它都非常熟悉。不过它也确实存在一个较大的不足。　每个请求都会派生出一个新的进程，而不是个新线程。此外这些　脚本程序的安全很难控制。现在较新的Ｊａｖａ　２的ｓｅｒｖｌｅｔ技术已　经克服了这些缺点。Ｓｏｒｖｌｅｔ引擎使用Ｊａｖａ技术在一个独立的线　程中启动每个ｓｅｒｖｉａ，并且用Ｊａｖａ技术来控制这些ｓｅｒｖｌｅｔ的安　全权限。当然，当数据发送给服务器时，数据究竟是由ＣＧＩ脚本　程序来进行转换，还是由ｓｅｒｖｌｅｔ来进行转换这并不重要。用户只　要用标准格式将数据发送服务器．而服务器则负责将这些数据　传递给生成应答的程序。　在将数据发送服务器时，常用ＰＯＳＴ方法。使用ＰＯＳＴ方法　时．是首先获取来自ＵＲＬ连接的输出数据流．并且将名字，值对　写入该输出数据流。但仍然必须对这些值进行ＵＲＬ编码，并且　用字符＆将这些值分开　在下面这个示例中．将通过Ｊａｖａ　Ｓｏｃｋｅｔ类建立一个Ｏｕｔ．　ｐｕｔＳｔｒｅａｍ类，用于实现ＰＯＳＴ传递操作。在用Ｓｏｃｋｅｔ类实现一　个传递操作时．必须建立一个到服务器的连接．并用ＡＳＣＩＩ码发　送以下的报头：　Ｐ０ＳＴ　ｆｄｅｎａｍｅ　Ｈ『丌　Ｐ，１．Ｏ　Ｃｏｎｔｅｎｔ－ｔｙｐｅ：ｔｙｐｅ　Ｃｏｎｔｅｎｔ－ｌｅｎｇｔｈ：ｌｅｎｇｔｈ　必须自己填入文件名、内容类型。以及内容的长度。内容的　类型指定了随后传送的数据的格式：此处我们使用ＭＩＮＥ类　型…ａｐｐｌｉｃａｔｉｏｎ＆一ＷＷＷ—ｆｏｒｍ—ｕｒｌｅｎｃｏｄｅｄ。内容的长度指定了剩　余的数据的长度。在这个报头之后，我们必须传送请求，我们必　须通过一个空白行将请求与报头分开。　与内容类型相符的请求主体应该具有以下的形式：ｋｅｙ１＝　ｖａｌｕｅｌ＆ｋｅｙ２－－ｖａｌｕｅ２．．　必须填入想发送的所有变量的键和值．这些键和值的内容　必须用ＵＲＬ码来进行编码．其中．需要替换所有的非ＡＳＣＩＩ码　字符和一些带有转义符的ＡＳＣＩＩ码字符　这些转义符由一个百　分号，加上两字节长的十六进制字符组成。　１．实现Ｐ０ｓＴ操作的ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ输出流类　此类是一个实现ＰＯＳＴ传递操作的ＯｕｔｐｕｔＳｔｍａｍ类　它先　对所有写入的数据进行缓冲。然后。当调用ｐｏｓｔＯ￣Ｊ＂法时．它连接　到指定的ＵＲＬ并传递数据，同时返回一个ＩｎｐｕｔＳｔｒｅａｍ．从这个　流中能够读取服务器的响应　这个类除了具有ｐｏｓｔＯ方法和ＯｕｔｐｕｔＳｔｒｅａｍ的普通方法外．　它还提供了ｗｒｉｔｅＳｔｒｉｎｇ０、ｗｒｉｔｅＴａｇ０、ｗｒｉｔｅＴａｇ８Ｏ等三个方法。其中　ｗｒｉｔｅＳｔｒｉｎｇ０方法能够写入一个ＡＳＣＩＩ编码的Ｓｔｒｉｎｇ：ｗｒｉｔｅＴａｇ０方　法能够写入一个ＵＰ＆编码的变量值对：ｗｒｉｔｅＴａｇｓ０方法能够写入　包含了ＵＲＬ编码的变量值对的Ｐｒｏｐｅｒｔｉｅ８　ｃｌａｓｓ　ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ　ｅｘｔｅｎｄｓ　ＦｉｈｅｒＯｕｔｐｕｔＳｔｒｅａｍ｛　／／ｐｕｂｌｉｃ　ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ（ＵＲＬ　ｕｒ１）；　／／ｐｕｂｌｉｃ　ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ（ＵＢＬ　ｕｒ１．Ｓｔｒｉｎｇ　ｃｏｎｔｅｎｔＴｙｐｅ）；　／／ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｒｌｔｅ．Ｓｔｒｌｎｇ（Ｓｔｒｌｎｇ　ｓｔｒｉｎｇ）ｔｈｒｏｗｓ　ＩＯＥｘｃｖｐｔｉｏｎ；　／／ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｒｉｔｅＴａｇ（Ｓｔｒｉｎｇ　ａｔｔｒ，Ｓｔｒｉｎｇ　ｖａｌｕｏ）ｔｂ　ｗ８　ＩＯＥｘｅｅｐｔｉｏｎ；　／／ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｒｉｔｅＴａｇａ（Ｐｒｏｐｅｒｔｌｅｓ　ｒｏｓｓ）ｔｈｒｏｗｓ　ＩＯＥｘｃｅｐｔｉｏｎ；　／／ｐｕｂｌｉｃ　ＩｎｐｕｌＳｔｒｅｍ＇ｎ　ｐｏｓｔ０　ｔｈｗｗｓ　ｌＯＥｘｅｅｐｔｉｏｎ；｝　这个类继承了ＦｉｈｅｒＯｕｔｐｕｔＳｔｒｅａｍ类。在传递数据之前．程序　将用ＦｉｌｔｅｒＯｕｔｐｕｔＳｔｒｅａｍ类的方法来把数据缓冲到一个ＢｖｔｅＡｒ．　ｒａｙＯｕｔｐｕｔＳｔｒｅａｍ对象中。　ｐｕｂｌｉｃ　ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ（ＵＲＬ　ｕｒ１）ｆ　ｔｈｉｓ（ｕｒｌ，”ａｐｐｌｉｃａｔｉｏｎ／ｘ—ｗｗｗ－ｆｏｒｍ—ｕｄｅｎｃｏｄｅｄ”）；ｌ　这个构造器具有一个参数ｕＩ１．这一参数指定了传递请求的　目的地的ＵＲＬ。程序将对所传递的数据使用默认的内容类型。　ｐｕｂｌｉｃ　ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ（ＵＲＬ　ｕｒｌ，Ｓｔｒｉｎｇ　ｃｏｎｔｅｎｔＴｙｐｅ）ｆ　ｓｕｐｅｒ（ｎｅｗ　ＢｙｔｅＡｒｒａｙＯｕｔｐｕｔＳｔｒｅａｍ０）；　ｂｙｔｅＡｒｒａｙＯｕｔ＝（ＢｙｔｅＡｒｒａｙＯｕｔｐｕｔＳｔｒｅａｍ）ｏｕｔ；　ｔｈｉｓ．ｕｒｌ＝ｕｒｌ；ｔｈｉｓ．ｃｏｎｔｅｎｔＴｙｐｅ＝ｃｏｎｔｅｎｔＴｙｐｅ；ｌ　这个构造器具有两个参数：一个目标ＵＲＬ（ｕｒ１）和一个内容　类￣（ｃｏｎｔｅｎｔＴｙｐｅ）。它传递一个新的ＢｙｔｅＡｒｒａｙＯｕｔｐｕｔＳｔｒｅａｍ对象　给它的父类构造器。同时程序为这个ＢｙｔｅＡｒｒａｙＯｕｔｐｕｔＳｔｒｅａｍ对　象建立一个局部引用．并将这个引用保存在ｂｙｔｅＡｒｒａｙＯｕｔ变量　中。程序中使用的ｏｕｔ变量是从父类中继承而来的，这个ｏｕｔ变　量同与之相连的流保持一致。程序将实现的传递请求挂起．同时　将所有写到ＰｏｓｔＯｕｔｐｕｔＳｔｒｅａｍ的数据将写入到ｂｙｔｅＡｒｒａｙＯｕｔ变　量中．并把这些数据加以缓冲。　ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｆｉｔｅＳｔｒｉｎｇ（Ｓｔｒｉｎｇ　ｓｔｒｉｎｇ）ｔｈｒｏｗｓ　ＩＯＥｘｃｅｐｔｉｏｎｆ　ｗｒｉｔｅ（ｓｔｒｉｎｇ．ｇｅｔＢｙｔｅｓ（”ｌａｔｉｎｌ”））；｝　这个方法通过调用Ｓｔｒ／ｎｇ类的ｇｅｔＢｙｔｅｓ０方法写一个ＡＳＣＩＩ　编码的Ｓｔｒｉｎｇ．同时采用ｌａｔｉｎ　１字符编码　ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｒｉｔｅＴａｇ（Ｓｔｒｉｎｇ　ａｔｔｒ，Ｓｔｒｉｎｇ　ｖａｌｕｅ）ｔｈｒｏｗｓ　ＩＯＥｘｃｅｐ－　ｔｉｏｎｆ　ｉｆ（ｂｙｔｅＡｒｒａｙＯｕｔ．ｓｉｚｅ　０＞Ｏ）ｗ４【ｅ（，＆＂）；ｗｒｉｔｅＳｔｒｉｎｇ（ＵＲＬＥｎｃｏｄｅｒ．　ｅｎｃｏｄｅ（ａｔｔｒ））；　ｗｒｉｔｅ（　＝＇）；ｗｒｉｔｅＳｔｒｉｎｇ（ＵＲｌ＿￣ｎｅｏｄｅｒ．ｅｎｃｏｄｅ（ｖａｌｕｅ））；｝　这个方法是写入采用ＵＲＬ编码的变量值对　首先检查　ＢｙｔｅＡｒｒａｙＯｕｔｐｕｔＳｔｒｅａｍ对象是否为空．如果不为空．程序假定这　不是第一个变量值对，于是程序写入一个”＆”分隔符。然后。程序　对这个变量的名称ａｔｔｒ进行ＵＲＬ编码．并将写之．接下来写入　一个”＝”分隔符。最后写入经过ＵＲＬ编码的值ｖａｌｕｅ。ＵＲＬ编码　方法我们用的是ｉａｖａ．ｎｅｔ．ＵＲＬＥｎｃｏｄｅｒ类的静态方法ｅｎｃｏｄｅ　（Ｓｔｒｉｎｇ　８）。　ｐｕｂｌｉｃ　ｖｏｉｄ　ｗｒｉｔｅＴａｇｓ（Ｐｍｐｅｒｔｉｅｓ　ｔａｇｓ）ｔｈｒｏｗｓ　ＩＯＥｘｃｅｐｔｉｏｎｌ　（下转第１９１页）

java基于协议与硬件通信流程

Java基于协议与硬件通信流程

在现代的信息时代，计算机与网络技术的快速发展使得计算机与各种硬件设备之间的通信变得日益重要和普遍。而Java作为一种跨平台的编程语言，具有强大的网络通信能力，可以方便地与各种硬件设备进行通信。本文将介绍Java基于协议与硬件通信的流程。

1. 硬件设备与协议

在硬件通信中，硬件设备通常会遵循特定的通信协议进行数据的交换。通信协议定义了通信的规则和格式，使得不同设备能够相互理解和交流。常见的硬件通信协议有串口通信协议（如RS232、RS485）、网络通信协议（如TCP/IP、UDP）等。

2. Java与硬件通信

Java作为一种面向对象的编程语言，提供了丰富的网络编程接口和库，使得开发者可以方便地与硬件设备进行通信。Java通过Socket类提供了对TCP/IP协议的支持，通过DatagramSocket类提供了对UDP协议的支持，通过SerialPort类提供了对串口通信的支持等。

3. Java基于协议与硬件通信的流程

Java基于协议与硬件通信的流程通常包括以下几个步骤：

3.1 创建与硬件设备之间的通信连接

在Java中，通过不同的类和方法可以创建与硬件设备之间的通信连接。对于网络通信，可以使用Socket类的构造函数创建与服务器的连接；对于串口通信，可以使用SerialPort类的openPort方法打开串口。

3.2 发送数据到硬件设备

一旦与硬件设备建立了通信连接，Java程序可以通过相应的类和方法将数据发送到硬件设备。对于网络通信，可以使用Socket类的getOutputStream方法获取输出流，然后通过write方法发送数据；对于串口通信，可以使用SerialPort类的getOutputStream方法获取输出流，然后通过write方法发送数据。

3.3 接收硬件设备的数据

在与硬件设备通信的过程中，Java程序通常需要接收硬件设备发送的数据。对于网络通信，可以使用Socket类的getInputStream方法获取输入流，然后通过read方法接收数据；对于串口通信，可以使用SerialPort类的getInputStream方法获取输入流，然后通过read方法接收数据。

【Java】Javasocket通信使⽤read,readline函数的阻塞问题

Socket通信是Java⽹络编程中⽐较基础的部分，其原理其实就是源ip，源端⼝和⽬的ip，⽬的端⼝组成的套接字通信。其底层还设及到了

TCP协议的通信。

Java中的Socket通信可以通过客户端的Socket与服务端的ServerSocket通信，同时利⽤IO流传递数据，也就是说Socket通信是⾯向流的使

⽤的是BIO，并不同于后来的NIO通信⾯向缓冲。Socket通信中使⽤的IO流的read，readline等函数都是阻塞的，这就导致了在通信过程中，

双⽅不能确定什么时侯是流的结束，针对这种可以通过约定结束符的⽅式进⾏结束，也可以约定⼀次传输的字节流的长度。下⾯通过代码进

⾏说明

客户端

建⽴客户端线程，在run⽅法中不断对服务端进⾏发送消息，模拟多个客户端的通信，通过写⼊换⾏符，表明这次通信的结束。

1 class Client implements Runnable {

2

3 private byte[] targetIp;

4 private int port;

5

6 Client(byte[] ip, int port) {

7 this.targetIp = ip;

8 this.port = port;

9 }

10

11 @Override

12 public void run() {

13 try {

14 InetAddress inetAddress = InetAddress.getByAddress(targetIp);

15 Socket socket = new Socket(inetAddress, port);

16 System.out.println("client");

17 BufferedReader socketInput = new BufferedReader(new InputStreamReader(socket.getInputStream()));