java如何实现socket连接⽅法封装
⽬录
Java实现socket连接技巧
Java Socket的封装
1 客户端Socket API要点
2 服务端Socket API要点
常见问题
Java使⽤socket实现⼀个多线程web服务器的⽅法
除了服务器类，还包括请求类和响应类
服务器处理类
请求类
响应类
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 clientSocket = new Socket();
//这个TimeOut是连接等待时间
2、当客户端已经连接, 每次收到⼀个数据, 客户端将启动处理, 假如服务器长久不发数据，此时客户端会阻塞等待, 为了避免这个时候的等待, 可以设置⼀个超时
clientSocket.setSoTimeout(timeOut);
Java使⽤socket实现⼀个多线程web服务器的⽅法
除了服务器类，还包括请求类和响应类
请求类：获取客户的HTTP请求，分析客户所需要的⽂件响应类：获得⽤户请求后将⽤户需要的⽂件读出，添加上HTTP应答头。发送给客户端。
服务器处理类
package com.lp.app.webserver;
import java.io.*;
import java.*;
//使⽤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 ("\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 ());
{
System.out.println ("关闭连接...\n");
//最后释放资源
try{
if (in != null)
in.close ();
if (out != null)
out.close ();
if (sk != null)
sk.close ();
}
catch (IOException e)
{
}
socket通信为什么要指定端口}
}
}
请求类
package com.lp.app.webserver;
import java.io.*;
import java.*;
//获取客户的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.String());
return String());
}
//获取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;
}
}
响应类
package com.lp.app.webserver;
import java.io.*;
import java.*;
//获得⽤户请求后将⽤户需要的⽂件读出，添加上HTTP应答头。发送给客户端。public class Response{
OutputStream out = null;
//发送请求的⽂件 public void Send(String ref) throws IOException {
byte[] bytes = new byte[2048];
FileInputStream fis = null;
File file = new File(WebServer.WEBROOT, ref);
if (ists()) {
//构造输⼊⽂件流
fis = new FileInputStream(file);
int ch = ad(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.Bytes());
}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.Bytes());
}
}
catch (Exception e) {
// 如不能实例化File对象，抛出异常。
System.out.String() );
}
finally {
if (fis != null)
fis.close();
}
}
//获取输出流
public Response(OutputStream output) {
this.out = output;
}
}
以上为个⼈经验，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。