Java中怎么实现Socket通信

本篇文章为大家展示了Java中怎么实现 Socket通信，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

创新互联是一家以重庆网站建设、网页设计、品牌设计、软件运维、成都网站推广、小程序App开发等移动开发为一体互联网公司。已累计为履带搅拌车等众行业中小客户提供优质的互联网建站和软件开发服务。

1.长连接、短链接只是针对客户端而言，服务器无所谓长、短；

2.无论同步或者异步通信，发送之后务必要又响应回复，确认收到，负责进行一定范围内重发，例如重发三次；

3.长连接服务器与客户端之间务必需要心跳探测，由客户端主动发起；

4.短连接服务器通用代码：

package com.biesan.sms.gate.unioncom.communication;  
import com.biesan.commons.Constants;  
import com.biesan.commons.util.CodeUtil;  
import com.biesan.sms.gate.unioncom.data.*;  
import com.biesan.sms.gate.unioncom.util.GateInfo;  
import java.net.*;  
import java.io.*;  
import java.util.*;  
import org.apache.log4j.*;  
import spApi.*;  
public class UnioncomDeliver extends Thread {  
// stop flag  
private boolean unInterrupt = true;  
private boolean unErr = true;  
//private boolean closeSocketFlag = false;  
// server socket  
private ServerSocket serverSo = null;  
// current socket  
private Socket so = null 
private OutputStream output = null;  
private InputStream input = null;  
// gate command  
private SGIP_Command tmpCmd = null;  
private SGIP_Command cmd = null;  
private Bind bind = null;  
private BindResp bindResp = null;  
//private Unbind unBind = null;  
private UnbindResp unBindResp = null;  
private boolean unAcceptErrorFlag = true;  
Logger unioncomLog = Logger.getLogger(Unioncom
Deliver.class.getName());  
public UnioncomDeliver() {  
}  
public void run() {  
unioncomLog.info("Start...");  
while (unInterrupt) {  
this.initServer();  
this.startServices();  
while (this.unAcceptErrorFlag) {  
try {  
//接受连接请求  
unioncomLog.info("before accept connection!....... 
FreeMemroy :" + Runtime.getRuntime().freeMemory());  
this.acceptConnection();  
unioncomLog.info("after accept connection!....... 
FreeMemroy :" + Runtime.getRuntime().freeMemory());  
while (unErr) {  
cmd = new Command();  
unioncomLog.info("before read command from stream
........... FreeMemroy: " + Runtime.getRuntime().
freeMemory());  
tmpCmd = cmd.read(input);  
unioncomLog.info("after read command from stream " + 
getCommandString(cmd.getCommandID()) + " FreeMemroy: " + 
Runtime.getRuntime().freeMemory());  
if (tmpCmd == null) {  
unErr = false;  
break;  
}  
switch (cmd.getCommandID()) {  
// biad ready communication  
case SGIP_Command.ID_SGIP_BIND: {  
this.dealBind();  
break;  
}// exit bind  
case SGIP_Command.ID_SGIP_UNBIND: {  
this.dealUnBind();  
unioncomLog.info("after unbind connection!....... 
FreeMemroy :" + Runtime.getRuntime().freeMemory());  
break;  
}// deliver  
....  
default : //错误的命令字  
break;  
}// switch  
}// while(unErr)  
} catch (Exception e) {  
unioncomLog.error("Unioncom Recv Service Error"  
+ e.getMessage());   
} finally {  
if (this.so != null) {  
this.closeSocket();  
}  
this.unErr = true;  
}  
}// while (this.unAcceptErrorFlag)  
try {  
this.closeServerSocket();  
sleep(200);// sleep  
} catch (InterruptedException ie) {  
}  
}// while(unInterrupt)  
}  
private String getCommandString(int cmd){  
switch (cmd) {  
// biad ready communication  
case SGIP_Command.ID_SGIP_BIND: {  
return " BIND COMMAND ";   
}// exit bind  
case SGIP_Command.ID_SGIP_UNBIND: {  
return " UNBIND COMMAND ";   
}// deliver  
case ...  
default:  
return " UNKNOWN COMMAND";   
}  
}  
private void dealBind() {  
try {  
bind = new Bind(tmpCmd);  
if (bind.readbody() != 0) {  
unioncomLog.warn("Read Bind error");  
this.unErr = false;  
}  
bindResp = new BindResp(tmpCmd.getMsgHead());  
bindResp.SetResult(0);  
bindResp.write(output);  
unioncomLog.debug("Bind success!");  
} catch (Exception e) {  
unioncomLog.error("Dela Union Recv Bind Error!" + 
e.getMessage());  
this.unErr = false;  
}  
}  
private void dealUnBind() {  
try {  
//unBind = (Unbind) tmpCmd;  
unBindResp = new UnbindResp(tmpCmd.getMsgHead());  
unBindResp.write(output);  
unioncomLog.debug("UnBind success!");  
} catch (Exception e) {  
unioncomLog.warn("Unbind error!" + e.getMessage());  
}  
this.unErr = false;  
}  
private void startServices() {  
boolean unStartServices = true;  
while (unStartServices) {  
try {  
serverSo = new ServerSocket(ugInfo.getLocalServerPort(), 5,  
InetAddress.getByName(ugInfo.getLocalIpAdd()));  
//serverSo.setSoTimeout(60000);  
unStartServices = false;   
unioncomLog.info("Create union recv socket Ok!");  
} catch (IOException e) {  
unioncomLog.warn("Create union recv socket error!"  
+ e.getMessage());  
unStartServices = true;  
UnioncomSubmit.thrSlp(3000);  
}  
}  
}  
private void acceptConnection() {  
// Accept 失败  
try {   
so = serverSo.accept();  
so.setSoTimeout(10000);  
} catch (Exception e) {  
unioncomLog.warn("Accept Error!" + e.getMessage());  
this.closeServerSocket();  
this.unAcceptErrorFlag = false;  
this.unErr=false;  
}  
// Accept成功  
try {  
input = so.getInputStream();  
output = so.getOutputStream();  
} catch (IOException e) {  
unioncomLog.warn("Get I/O stream Error!" + e.getMessage());  
this.closeService();  
this.unAcceptErrorFlag = false;  
this.unErr=false;  
}  
}  
private void closeSocket() {  
try {  
so.close();  
unioncomLog.info("Socket Close Success!!!");  
} catch (Exception e) {  
unioncomLog.error("Socket Close Failure!!!" + e.getMessage());  
}  
}  
private void closeServerSocket() {  
try {  
serverSo.close();  
unioncomLog.info("ServerSocket Close Success!!!");  
} catch (Exception e) {  
unioncomLog  
.error("ServerSocket Close Failure!!!" + e.getMessage());  
}  
}  
private void closeService() {  
this.closeSocket();  
this.closeServerSocket();  
}  
private void initServer() {  
this.bind = null;  
this.bindResp = null;  
//this.unBind = null;  
this.unBindResp = null;  
this.tmpCmd = null;  
this.cmd = null;  
this.serverSo = null;  
this.so = null;  
this.output = null;  
this.input = null;  
this.unErr = true;  
//this.closeSocketFlag = false;  
unioncomLog.info("Memory***==="  
+ java.lang.Runtime.getRuntime().freeMemory());  
}  
public synchronized void requireStop() {  
this.unInterrupt = false;  
unioncomLog.info("Requre interrupt!!!");  
}  
public String convertMsgContentCoding
(int msgCoding, byte[] msgContent) {  
String deliverContent = null;  
try {  
if (msgContent != null) {  
if (msgCoding == 8) { // 处理ucs32编码  
deliverContent = new String(msgContent,  
"UnicodeBigUnmarked");  
} else if (msgCoding == 0) { // 处理ASCII编码  
deliverContent = new String(msgContent, "ASCII");  
} else if (msgCoding == 4) { // 处理binary编码  
deliverContent = new String(msgContent);  
} else if (msgCoding == 15) { // 处理GBK编码  
deliverContent = new String(msgContent, "GBK");  
// 处理DELIVER数据包的短信息ID  
} else {  
unioncomLog.error("编码格式错误!");  
return "";  
}  
} else  
return "";  
return deliverContent;  
} catch (UnsupportedEncodingException ex) {  
unioncomLog.error("deal content error!" +
 ex.getMessage());  
return "";  
}  
}  
} 

上述内容就是Java中怎么实现 Socket通信，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。