Java中怎么實現(xiàn) Socket通信

本篇文章為大家展示了Java中怎么實現(xiàn) Socket通信，內容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

1.長連接、短鏈接只是針對客戶端而言，服務器無所謂長、短；

2.無論同步或者異步通信，發(fā)送之后務必要又響應回復，確認收到，負責進行一定范圍內重發(fā)，例如重發(fā)三次；

3.長連接服務器與客戶端之間務必需要心跳探測，由客戶端主動發(fā)起；

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中怎么實現(xiàn) Socket通信，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注億速云行業(yè)資訊頻道。