Java Socket

什么是Socket

Socket的概念很简单,它是网络上运行的两个程序间双向通讯的一端,既可以接收请求,也可以发送请求,利用它可以较为方便地编写网络上数据的传递

所以简而言之,Socket就是进程通信的端点,Socket之间的连接过程可以分为几步:

1、服务器监听

服务器端Socket并不定位具体的客户端Socket,而是处于等待连接的状态,实时监控网络状态

2、客户端请求

客户端Socket发出连接请求,要连接的目标是服务端Socket。为此,客户端Socket必须首先描述它要连接的服务端Socket,指出服务端Socket的地址和端口号,然后就向服务端Socket提出连接请求

3、连接确认

当服务端Socket监听到或者说是接收到客户端Socket的连接请求,它就响应客户端Socket的请求,建立一个新的线程,把服务端Socket的描述发给客户端,一旦客户端确认了此描述,连接就好了。而服务端Socket继续处于监听状态,继续接收其他客户端套接字的连接请求

TCP/IP、HTTP、Socket的区别

这三个概念是比较容易混淆的概念,这里尽量解释一下三者之间的区别。

随着计算机网络体系结构的发展,OSI七层网络模型诞生了,这个模型把开放系统的通信功能划分为七个层次,一次完整的通信如下图:

每一层都是相互独立的,它利用其下一层提供的服务并为其上一层提供服务,而与其它层的具体实现无关,所谓"服务"就是下一层向上一层提供的通信功能和层之间的会话约定,一般用通信原语实现。上图中,从下至上分别给层编号为1~7,其中1~4层为下层协议,5~7层为上层协议,接着回到我们的概念:

1、TCP/IP讲的其实是两个东西:TCP和IP。IP是一种网络层的协议,用于路由选择、网络互连

2、TCP是一种传输层协议,用于建立、维护和拆除传送连接,在系统之间提供可靠的透明的数据传送

3、HTTP是一种应用层协议,提供OSI用户服务,例如事物处理程序、文件传送协议和网络管理等,其目的最终是为了实现应用进程之间的信息交换

至于Socket,它只是TCP/IP网络的API而已,Socket接口定义了许多函数,用以开发TCP/IP网络上的应用程序,组织数据,以符合指定的协议。

Socket的两种模式

Socket有两种主要的操作方式:面向连接和无连接的。面向连接的Socket操作就像一部电话,必须建立一个连接和一人呼叫,所有事情在达到时的顺序与它们出发时的顺序一样,无连接的Socket操作就像是一个邮件投递,没有什么保证,多个邮件可能在达到时的顺序与出发时的顺序不一样。

到底使用哪种模式是由应用程序的需要决定的。如果可靠性更重要的话,用面向连接的操作会好一些,比如文件服务器需要数据的正确性和有序性,如果一些数据丢失了,系统的有效性将会失去;比如一些服务器间歇性地发送一些数据块,如果数据丢失了的话,服务器并不想要再重新发送一次,因为当数据到达的时候,它可能已经过时了。确保数据的有序性和正确性需要额外的操作的内存消耗,额外的消耗将会降低系统的回应速率。

无连接的操作使用数据报协议。一个数据报是一个独立的单元,它包含了所有这次投递的信息,就像一个信封,它有目的地址和要发送的内容,这个模式下的Socket并不需要连接一个目的Socket,它只是简单地透出数据报,无连接的操作是快速、高效的,但是数据安全性不佳。

面向连接的操作使用TCP协议。一个这个模式下的Socket必须在发送数据之前与目的地的Socket取得一个连接,一旦连接建立了,Socket就可以使用一个流接口:打开-->读-->写-->关闭,所有发送的信息都会在另一端以同样的顺序被接收。面向连接的操作比无连接的操作效率更低,但是数据的安全性更高。

利用Java开发Socket

在Java中面向连接的类有两种形式,它们分别是客户端和服务器端,先看一下服务器端:

public class HelloServer

{

public static void main(String[] args) throws IOException

{

ServerSocket serverSocket = null;

try

{

// 实例化一个服务器端的Socket连接

serverSocket = new ServerSocket(9999);

}

catch (IOException e)

{

System.err.print("Could not listen on port:9999");

System.exit(1);

}

Socket clientSocket = null;

try

{

// 用于接收来自客户端的连接

clientSocket = serverSocket.accept();

}

catch (IOException e)

{

System.err.println("Accept failed");

System.exit(1);

}

// 客户端有数据了就向屏幕打印Hello World

System.out.print("Hello World");

clientSocket.close();

serverSocket.close();

}

}

此代码的作用就是构造出服务端Socket,并等待来自客户端的消息。当然,此时运行代码是没有任何反应的,因为服务端在等待客户端的连接。下面看一下客户端代码如何写:

public class HelloClient

 {

 public static void main(String[] args) throws IOException

{

Socket socket = null;

BufferedReader br = null;

// 下面这段程序,用于将输入输出流和Socket相关联

 try

 {

 socket = new Socket("localhost", 9999);

br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

}

catch (UnknownHostException e)

 {

 System.err.println("Don't know about host:localhost");

 System.exit(1);

 }

catch (IOException e)

 {

System.err.println("Could not get I/O for the connection");

 System.exit(1);

 }

System.out.print(br.readLine());

br.close();

socket.close();

 }

}

此时只需要先运行HelloServer,再运行HelloClient,保证服务器先监听,客户端后发送,就可以在控制台上看到"Hello World"了。

改进版本的Socket

上面的Socket演示的效果是,服务器端Socket收到了来自客户端Socket的数据,但是并没有真正地体现服务器端Socket和客户端Socket的交互,下面演示一下利用Socket进行服务器端和客户端的交互,首先是服务器端的:

public class EchoServer

 {

 public static void main(String[] args) throws IOException

{

 ServerSocket ss = null;

PrintWriter pw = null;

BufferedReader br = null;

try

 {

 // 实例化监听端口

 ss = new ServerSocket(1111);

 }

 catch (IOException e)

 {

System.err.println("Could not listen on port:1111");

System.exit(1);

 }

Socket incoming = null;

 while (true)

 {

 incoming = ss.accept();

 pw = new PrintWriter(incoming.getOutputStream(), true);

 // 先将字节流通过InputStreamReader转换为字符流,之后将字符流放入缓冲之中

 br = new BufferedReader(new InputStreamReader(incoming.getInputStream()));

 // 提示信息

pw.println("Hello!...");

 pw.println("Enter BYE to exit");

pw.flush();

// 没有异常则不断循环

 while (true)

 {

 // 只有当用户输入时才返回数据

 String str = br.readLine();

 // 当用户连接断掉时会返回空值null

 if (str == null)

 {

// 退出循环

break;

}

else

{

// 对用户输入字符串加前缀Echo并将此信息打印到客户端

pw.println("Echo:" + str);

pw.flush();

// 退出命令,equalsIgnoreCase()是不区分大小写的

if ("BYE".equalsIgnoreCase(str.trim()))

{

break;

}

}

}

// 该close的资源都close掉

pw.close();

br.close();

incoming.close();

ss.close();

}

}

}

接着是客户端的:

public class EchoClient

{

public static void main(String[] args) throws IOException

{

Socket socket = null;

PrintWriter pw = null;

BufferedReader br = null;

try

{

socket = new Socket("localhost", 1111);

pw = new PrintWriter(socket.getOutputStream(), true);

br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

}

catch (UnknownHostException e)

{

System.err.println("Don't know abount host:localhost");

System.exit(1);

}

System.out.println(br.readLine());

System.out.println(br.readLine());

BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));

String userInput;

// 将客户端Socket输入流(即服务器端Socket的输出流)输出到标准输出上

while ((userInput = stdIn.readLine()) != null)

{

pw.println(userInput);

System.out.println(br.readLine());

}

// 同样的,将该关闭的资源给关闭掉

pw.close();

br.close();

socket.close();

}

}

看一下运行结果:

这正是我们程序要达到的效果,客户端不管输入什么,服务器端都给输入拼接上"Echo:"返还给客户端并打印在屏幕上。

服务端多监听

程序写到上面,已经基本成型了,不过还有一个问题:现实情况中,一个服务器端的Socket不可能只对应一个客户端的Socket,必然一个服务器端的Socket可以接收来自多个客户端的Socket的请求。

解决上述问题的办法就是多线程。大致代码是这样的:

public class HandleThread extends Thread

{

private Socket socket;

public HandleThread(Socket socket)

{

this.socket = socket;

}

public void run()

{

// Socket处理代码

}

}

public static void main(String[] args) throws IOException

{

ServerSocket serverSocket = null;

try

{

// 实例化一个服务器端的Socket连接

serverSocket = new ServerSocket(9999);

}

catch (IOException e)

{

System.err.print("Could not listen on port:9999");

System.exit(1);

}

Socket clientSocket = null;

try

{

while (true)

{

// 用于接收来自客户端的连接

clientSocket = serverSocket.accept();

new HandleThread(clientSocket).start();

}

}

catch (IOException e)

{

System.err.println("Accept failed");

System.exit(1);

}

}

即,服务器端启动一个永远运行的线程,监听来自客户端的Socket,一旦客户端有Socket到来,即开启一个新的线程将Socket交给线程处理。

由服务端多监听程序看IO模型

上面的代码,用一张图来表示一下这种IO模型:

即由一个独立的Acceptor线程负责监听客户端的连接,它接收到客户端连接之后为每个客户端创建一个新的线程进行链路处理,处理完成之后,通过输出流返回应答给客户端,线程销毁。这就是典型的一请求一应答通信模型,也就是Blocking IO模型即BIO。

该模型最大的问题就是缺乏弹性伸缩能力,当客户端并发访问量增大后,服务端的线程个数和客户端并发访问数呈1:1的正比关系,由于线程是Java虚拟机非常宝贵的系统资源,当线程数膨胀之后,系统的性能将极具下降,随着并发访问量的继续增大,系统将会发生线程堆栈溢出、创建新线程失败等问题,并最终导致进程宕机或者僵死,不能对外提供服务。

在高性能服务器应用领域,往往要面向成千上万个客户端的并发连接,这种模型显然无法满足高性能、高并发接入的场景。

当然具体问题具体分析,BIO性能虽然差,但是编程简单,如果客户端并发连接数不多,周边对接的网元不多,服务器的负载也不重,那么完全可以使用BIO进行作为服务器的IO模型。

   为了让学习变得轻松、高效,今天给大家免费分享一套Java教学资源。帮助大家在成为Java架构师的道路上披荆斩棘。需要资料的欢迎加入学习交流群:9285,05736

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,922评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,591评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,546评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,467评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,553评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,580评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,588评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,334评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,780评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,092评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,270评论 1 344
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,925评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,573评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,194评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,437评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,154评论 2 366
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,127评论 2 352

推荐阅读更多精彩内容