服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - java如何实现socket连接方法封装

java如何实现socket连接方法封装

2022-01-17 12:18lemonmini Java教程

这篇文章主要介绍了java实现socket连接方法封装教程,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

Java实现socket连接技巧

Socket通信几乎无时不在,当然能够搜集到的信息也大量存在, 为了避免重复的劳作, 抽取了关于客户端和服务端的Socket, 并将其应用到适合JVM(LInux/Windows)或者DVM(Android)平台。

这个封装好的API具有以下优势:

1.满足具有Socket客户端需求的基本应用。

2.满足具有Socket服务端的基本应用。具备并发能力, 能满足可设定个数客户端连接。

本文的目的就是为了对Socket做一个封装, 方便客户端和服务端能直接使用Socket.封装好的API可以从下面获取

Java Socket的封装

其中src/中的是API源码; usage/目录是使用例程

1 客户端Socket API要点

1)客户端和指定的服务端相连, 因此客户端需要指明服务端对应的IP地址和端口号

2)需要设置超时返回

3)需要设置循环等待, 因为基本的Socket通信都是一来一回, 这种来回是通过阻塞来完成的。

4)每个客户端连入服务端的时候, 都具备本身的ID, 类似于HTTP的Session, 这点容易被忽视。在多客户端连接中, 可以重点关注。本文提供的代码也有所提及, 但没有深入, 这点留给读者进一步发掘。

代码参照/usage目录下的客户端测试代码, 注意, 先启动服务端,或者你拿着NetAssis 来测试也不错.

2 服务端Socket API要点

1)服务端一般是被多个客户端连接的, 并且这些连接要求服务端做相似的处理, 因此这里就将这些相似处理, 抽象成一个SingleTask.java 接口, 具体的业务只需要实现这样的接口, 就可以并行的处理这些Task.

2)不能无限制的让客户端连入Server, 因此需要设置上限值

3)启动线程池, 每个线程针对一个具体的客户端连接

4)注意接收阻塞位置, 需要设置死循环, 读不到数据将死守着等待(但别耽误其它线程处理事情)

5)注意服务端要在死循环中侦听, 这样保证不错过任何来自客户端的请求。

代码参照:/usage目录下的Server端测试代码。

代码中注释很多,因此这里就不详细述说。

常见问题

1、客户端Client的时候, 如果存在网络问题, 为了避免网络问题,造成客户端长时间等待, 此时要设置一个TimeOut

?
1
2
3
clientSocket = new Socket();
//这个TimeOut是连接等待时间
clientSocket.connect(tcpAddress, timeOut);

2、当客户端已经连接, 每次收到一个数据, 客户端将启动处理, 假如服务器长久不发数据, 此时客户端会阻塞等待, 为了避免这个时候的等待, 可以设置一个超时

?
1
clientSocket.setSoTimeout(timeOut);

Java使用socket实现一个多线程web服务器的方法

除了服务器类,还包括请求类和响应类

请求类:获取客户的HTTP请求,分析客户所需要的文件响应类:获得用户请求后将用户需要的文件读出,添加上HTTP应答头。发送给客户端。

服务器处理类

?
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//使用Socket创建一个WEB服务器,本程序是多线程系统以提高反应速度。
class WebServer
{
public static String WEBROOT = "";//默认目录
 public static String defaultPage = "index.htm";//默认文件
 public static void main (String [] args) throws IOException
 {
 System.out.println ("服务器启动...\n");
  //使用8080端口提供服务
 ServerSocket server = new ServerSocket (8080);
 while (true)
 {
  //阻塞,直到有客户连接
  Socket sk = server.accept ();
  System.out.println ("Accepting Connection...\n");
  //启动服务线程
  new WebThread (sk).start ();
 }
 }
}
//使用线程,为多个客户端服务
class WebThread extends Thread
{
 private Socket sk;
 WebThread (Socket sk)
 {
  this.sk = sk;
 }
 //线程体
 public void run ()
 {
  InputStream in = null;
  OutputStream out = null;
  try{
  in = sk.getInputStream();
  out = sk.getOutputStream();
  //接收来自客户端的请求。
  Request rq = new Request(in);
  //解析客户请求
  String sURL = rq.parse();
  System.out.println("sURL="+sURL);
  if(sURL.equals("/"))
    sURL = WebServer.defaultPage;
  Response rp = new Response(out);
  rp.Send(sURL);
   }
  catch (IOException e)
  {
  System.out.println (e.toString ());
  }
  finally
  {
  System.out.println ("关闭连接...\n");
  //最后释放资源
  try{
   if (in != null)
   in.close ();
   if (out != null)
   out.close ();
   if (sk != null)
   sk.close ();
  }
  catch (IOException e)
  {
  }
  }
 }
}

请求类

?
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
33
34
35
36
37
38
39
40
41
package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//获取客户的HTTP请求,分析客户所需要的文件
public class Request{
 InputStream in = null;
 //获得输入流。这是客户的请求数据。
 public Request(InputStream input){
 this.in = input;
 }
 //解析客户的请求
 public String parse() {
 //从Socket读取一组数据
 StringBuffer requestStr = new StringBuffer(2048);
 int i;
 byte[] buffer = new byte[2048];
 try {
 i = in.read(buffer);
 }
 catch (IOException e) {
 e.printStackTrace();
 i = -1;
 }
 for (int j=0; j<i; j++) {
 requestStr.append((char) buffer[j]);
 }
 System.out.print(requestStr.toString());
 return getUri(requestStr.toString());
 }
 //获取URI信息字符
 private String getUri(String requestString) {
 int index1, index2;
 index1 = requestString.indexOf(' ');
 if (index1 != -1) {
 index2 = requestString.indexOf(' ', index1 + 1);
 if (index2 > index1)
  return requestString.substring(index1 + 1, index2);
 }
 return null;
 }
}

响应类

?
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//获得用户请求后将用户需要的文件读出,添加上HTTP应答头。发送给客户端。
public class Response{
 OutputStream out = null;
 //发送请求的文件 public void Send(String ref) throws IOException {
 byte[] bytes = new byte[2048];
 FileInputStream fis = null;
 try {
 //构造文件
 File file = new File(WebServer.WEBROOT, ref);
 if (file.exists()) {
  //构造输入文件流
  fis = new FileInputStream(file);
  int ch = fis.read(bytes, 0, 2048);
  //读取文件
  String sBody = new String(bytes,0);
  //构造输出信息
  String sendMessage = "HTTP/1.1 200 OK\r\n" +
  "Content-Type: text/html\r\n" +
  "Content-Length: "+ch+"\r\n" +
  "\r\n" +sBody;
  //输出文件
  out.write(sendMessage.getBytes());
 }else {
  // 找不到文件
  String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +
  "Content-Type: text/html\r\n" +
  "Content-Length: 23\r\n" +
  "\r\n" +
  "<h1>File Not Found</h1>";
  out.write(errorMessage.getBytes());
 }
 }
 catch (Exception e) {
 // 如不能实例化File对象,抛出异常。
 System.out.println(e.toString() );
 }
 finally {
 if (fis != null)
  fis.close();
 }
 }
 //获取输出流
 public Response(OutputStream output) {
 this.out = output;
}
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。

原文链接:https://blog.csdn.net/lemonrel/article/details/103189358

延伸 · 阅读

精彩推荐
  • Java教程详解idea打包jar的多种方式

    详解idea打包jar的多种方式

    本篇文章总结出用IDEA打包jar包的多种方式。项目打包Jar包可以参考如下形式:用IDEA自带的打包形式;用Maven插件maven-shade-plugin打包;用Maven插件maven-assemb...

    byhieg3292020-07-22
  • Java教程mybatis中oracle实现分页效果实例代码

    mybatis中oracle实现分页效果实例代码

    实现分页的方式有很多,但常用的是通过SQL来显示分页。这篇文章主要介绍了mybatis中oracle实现分页效果实例代码,有兴趣的可以了解一下。...

    滥好人2962020-09-17
  • Java教程Java使用entrySet方法获取Map集合中的元素

    Java使用entrySet方法获取Map集合中的元素

    这篇文章主要为大家详细介绍了Java使用entrySet方法获取Map集合中的元素,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    Killer-V3782021-05-27
  • Java教程Java的字符串中对子字符串的查找方法总结

    Java的字符串中对子字符串的查找方法总结

    这篇文章主要介绍了Java的字符串中对子字符串的查找方法总结,是Java入门学习中的基础知识,需要的朋友可以参考下 ...

    iceFin5302020-01-13
  • Java教程Spring的Bean容器介绍

    Spring的Bean容器介绍

    今天小编就为大家分享一篇关于Spring的Bean容器介绍,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧...

    李灿辉5572021-06-30
  • Java教程MAC算法之消息摘要算法HmacMD5的实现

    MAC算法之消息摘要算法HmacMD5的实现

    这篇文章主要介绍了MAC算法之消息摘要算法HmacMD5的实现的相关资料,这里提供实例,帮助大家学习理解这部分知识,需要的朋友可以参考下...

    sahadev_1782020-12-11
  • Java教程Java项目--家庭收支记录程序

    Java项目--家庭收支记录程序

    本文主要介绍Java基础阶段的一个小项目——家庭收支记录程序(附完整源代码),本项目所用到的主要知识点:基本语法、数组和方法。本项目并不难,主...

    猿力满满11742021-10-29
  • Java教程使用spring的websocket创建通信服务的示例代码

    使用spring的websocket创建通信服务的示例代码

    这篇文章主要介绍了使用spring的websocket创建通信服务的示例代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...

    喵先生的进阶之路10102021-06-11