Java如何通过Socket实现TCP服务端

Socket 通常也称作“套接字”，Java如何通过Socket实现TCP服务端？下面本站小编带大家一起来看看详细内容，希望对大家有所帮助!想了解更多相关信息请持续关注我们应届毕业生考试网!

　　1 Java Socket简介

所谓socket 通常也称作”套接字“，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过”套接字”向网络发出请求或者应答网络请求。Socket和ServerSocket类库位于包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。

　　2 TCPServer代码实例

import ception;

import tStream;

import utStream;

import erSocket;

import et;

import ;

import Map;

import ;

import er;

import erFactory;

/**

* TCP服务器端,单例模式

* @author xiang

*

*/

public class TCPServer implements Runnable {

private static final Logger logger = ogger(s);

//成员变量/

private static TCPServer serverInstance;

private static Map<String, SocketThread> socketMaps = new HashMap<String,SocketThread>();　　　　　　　　//每个客户端连接时都会新建一个SocketThread与之对应 private static ServerSocket serverSocket; //服务器套接字

private static int serPort = 9999; //服务器端口号

private static boolean flag; //服务器状态标志

private static final int BUFFER_SIZE = 512; //数据接收字符数组大小

//构造函数/

private TCPServer() {

}

/**

* 获取实例

* @return TCPServer实例serverInstance

*/

public static TCPServer getServerInstance(){

if(serverInstance==null)

serverInstance = new TCPServer();

return serverInstance;

}

/**

* 开启服务器

* @throws IOException

*/

public void openTCPServer() throws IOException{ if(serverSocket==null || osed()){

serverSocket = new ServerSocket(serPort);

flag = true;

}

}

/**

* 关闭服务器

* @throws IOException

*/

public void closeTCPServer() throws IOException{

flag = false; if(serverSocket!=null)

e();

/*for (y<String, SocketThread> entry : ySet()) {

tln("Key = " + ey() + ", Value = " + alue());

} */

for (SocketThread value : es())

eConnect();

r();

}

/**

* 服务器向客户端发送数据

* @param bytes[]:待发送的字符数组

* @param key 客户端的key,为空或""时表示数据群发

* @throws IOException

*/

public void sendMessage(String key,byte[] msgBytes){

if(key==null||ls("")){

for (SocketThread value : es())

Massage(msgBytes);

}else{

SocketThread thread = (key);

if(thread!=null)

Massage(msgBytes);

}

}

/**

* 服务器向客户端发送数据

* @param key 客户端的`key,为空或""时表示数据群发

* @param msgStr:待发送的字符串

* @throws IOException

*/

public void sendMessage(String key,String msgStr){ byte[] sendByte = ytes();

if(key==null||ls("")){

for (SocketThread value : es())

Massage(sendByte);

}else{

SocketThread thread = (key);

if(thread!=null)

Massage(sendByte);

}

}

@Override

public void run() {

("服务器线程已经启动"); while(true){

try {

while(flag){

("服务器线程在监听状态中");

Socket socket = pt();

String key = emoteSocketAddress()ring();

SocketThread thread = new SocketThread(socket,key);

t();

(key, thread);

("有客户端连接："+key);

}

} catch (Exception e) {

tStackTrace();

}

}

}

/**

* 处理连接后的数据接收请求内部类

* @author xiang

*

*/

private class SocketThread extends Thread{

private Socket socket;

private String key;

private OutputStream out;

private InputStream in;

//构造函数

public SocketThread(Socket socket,String key) {

et = socket;

= key;

}

/**

* 发送数据

* @param bytes

* @throws IOException

*/

public void sendMassage(byte[] bytes){

try {

if(out==null)

out = utputStream();

e(bytes);

} catch (Exception e) {

tStackTrace();

try {

closeConnect();

} catch (IOException e1) {

tStackTrace();

}

ve(key);

}

}

/**

* 关闭连接，释放资源

* @throws IOException

*/

public void closeConnect() throws IOException{

if(out!=null) e();

if(in!=null) e();

if(socket!=null && nnected()) e();

}

@Override

public void run() {

byte[] receivBuf = new byte[BUFFER_SIZE];

int recvMsgSize;

try {

in = nputStream();

out = utputStream();

while ((recvMsgSize = (receivBuf)) != -1) {

String receivedData = new String(receivBuf, 0, recvMsgSize);

tln("Reverve form[port" + ort() + "]:" + receivedData);

tln("Now the size of socketMaps is" + ());

/**************************************************************

*

* 接收数据后的处理过程

*

**************************************************************/

}

// response to client

byte[] sendByte = "The Server has received"ytes();

// e(sendByte, 0, th);

e(sendByte);

tln("To Cliect[port:" + ort() + "] 回复客户端的消息发送成功");

closeConnect();

ve(key);

} catch (Exception e) {

tStackTrace();

try {

closeConnect();

} catch (IOException e1) {

tStackTrace();

}

}

}

//////////////

public int getport(){

return ort();

}

}

//. end SocketThread

}