好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

java实现Socket通信之单线程服务

前言

使用基于tcp 协议的双向通信时,网络中的两个应用程序之间必须首先建立一个连接,这两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。

建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(api),对tcp/ip的封装,tcp/ip也要提供可供程序员做网络开发所用的接口,这就是socket编程接口;http是轿车,提供了封装或者显示数据的具体形式;socket是发动机,提供了网络通信的能力。

socket的英文原义是[孔]或[插座]。作为bsd unix的进程通信机制,取后一种意思。通常也称作"套接字",用于描述ip地址和端口,是一个通信链的句柄,可以用来实现不同虚拟机或不同计算机之间的通信。在internet上的主机一般运行了多个服务软件,同时提供几种服务。每种服务都打开一个socket,并绑定到一个端口上,不同的端口对应于不同的服务。socket正如其英文原意那样,像一个多孔插座。一台主机犹如布满各种插座的房间,每个插座有一个编号,有的插座提供220伏交流电, 有的提供110伏交流电,有的则提供有线电视节目。 客户软件将插头插到不同编号的插座,就可以得到不同的服务。

使用 socket 的通信模式

java .net 程序包将基于tcp 通信的socket 封装为两个类:类socket 表达了一个用于建立tcp 连接的socket,该socket 既可由客户程序使用,也可由服务程序

使用;类serversocket 则是一个服务端专门监听客户程序连接请求的socket 的抽象,仅在服务程序中使用。

socket通信过程

服务器端:

                 ① 创建serversocket对象,绑定监听端口

                 ② 通过accept()方法监听客户端请求

                 ③ 连接建立后,通过输入流读取客户端发送的请求信息

                 ④ 通过输出流向客户端发送响应信息

                 ⑤ 关闭连接

客户端:
                 ① 创建socket对象,指明需要连接的服务器的地址和端口号

                 ② 连接建立后,通过输出流想服务器端发送请求信息

                 ③ 通过输入流获取服务器响应的信息

                 ④ 关闭连接

单线程 服务程序代码

服务端:

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

import java.net.*;

import java.io.*;

 

public class echoserver {

   public static void main(string[] args) throws ioexception {

     if (args.length != 1 ) {

       system.out.println( "用法:echoserver <端口号>" );

       return ;

     }

 

     // 监听客户程序的连接请求

     serversocket listensocket = new serversocket(integer.parseint(args[ 0 ]));

     system.out.println( "服务程序正在监听端口" + args[ 0 ]);

     socket socket = listensocket.accept();

     // 从与客户程序的新建连接获取输入流和输出流

     printwriter out = new printwriter(socket.getoutputstream(), true );

     bufferedreader in = new bufferedreader( new inputstreamreader

       (socket.getinputstream()));

     // 从客户端读取数据,并写回数据的加工结果

     string message;

     while ((message = in.readline()) != null ) {

       system.out.println( "收到请求:" + message);

       out.println(message.touppercase());

     }

 

     // 关闭连接

     out.close();

     in.close();

     socket.close();

     listensocket.close();

   }

}

客户端:

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

import java.net.*;

import java.io.*;

 

public class echoclient {

   public static void main(string[] args) throws exception {

     if (args.length != 2 ) {

       system.out.println( "用法:echoclient <主机名> <端口号>" );

       return ;

     }

 

     // 建立连接并打开相关联的输入流和输出流

     socket socket = new socket(args[ 0 ], integer.parseint(args[ 1 ]));

     system.out.println( "当前socket信息:" + socket);

     printwriter out = new printwriter(socket.getoutputstream(), true );

     bufferedreader in = new bufferedreader( new inputstreamreader

       (socket.getinputstream()));

 

     // 将控制台输入的字符串发送给服务端,并显示从服务端获取的处理结果

     bufferedreader stdin = new bufferedreader( new inputstreamreader

       (system.in));

     string userinput;

     while ((userinput = stdin.readline()) != null ) {

       out.println(userinput);

       system.out.println( "返回:" + in.readline());

     }

     stdin.close();

     // 关闭连接

     out.close();

     in.close();

     socket.close();

   }

}

运行结果示例(基于windows)

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

原文链接:https://blog.csdn.net/zhaokx3/article/details/52513019

查看更多关于java实现Socket通信之单线程服务的详细内容...

  阅读:39次