用ServerSocket和Socket來編寫伺服器程式和客戶程式，是Java網路程式設計的最基本的方式。這些伺服器程式或客戶程式在執行過程中常常會阻塞。例如當一個執行緒執行ServerSocket的accept()方法時，假如沒有客戶連線，該執行緒就會一直等到有了客戶連線才從accept()方法返回。再例如當執行緒執行Socket的read()方法時，如果輸入流中沒有資料，該執行緒就會一直等到讀入了足夠的資料才從read()方法返回。 兩種方法可以嘗試對比一下

第一種socket程式設計:
//首先建立socket連線
socket socket = new Socket(address,port); 
// 傳送請求到服務端面
@param eql  為要傳送的字元
public String sendMessageServer(Socket socket, String eql) {
//此方法將前4位做為位元組長度，後面跟所傳送的位元組
try {
String firstMessage = eql + "\n\0";
int meslength = firstMessage.length();
// 將長度轉換為無符號byte
byte[] b = toLH(meslength);
//得到字元的位元組數
int count = firstMessage.getBytes().length;
byte[] buf = new byte[count + 4];
// 將長度答存入同一個byte陣列字
System.arraycopy(b, 0, buf, 0, b.length);
System.arraycopy(firstMessage.getBytes(), 0, buf, 4, count);
out = socket.getOutputStream();
out.write(buf);
out.flush(); 
} catch (Exception e) {
e.printStackTrace();
}
return "";
} 
// 接收服務端返回的資料
public String receiveMessageClient(Socket socket) {
String json = "";
try {
in = new InputStreamReader(socket.getInputStream());
int tempchar;
while ((tempchar = in.read()) != -1) {
if (((char) tempchar) != '\r') {
System.out.print((char) tempchar);
json += (char) tempchar +"";
}
}
} catch (Exception e) {
e.printStackTrace();
}
return json;
}

// 將int資料轉換為0~4294967295 (0xFFFFFFFF即DWORD)。
public long getUnsignedIntt(int data) {
return data & 0x0FFFFFFFFl;
}


/**
* 將int轉為低位元組在前，高位元組在後的byte陣列
*/
private static byte[] toLH(int n) {
byte[] b = new byte[4];
b[3] = (byte) (n & 0xff);
b[2] = (byte) (n >> 8 & 0xff);
b[1] = (byte) (n >> 16 & 0xff);
b[0] = (byte) (n >> 24 & 0xff);
return b;
}


/**
* 將int轉為低位元組在前，高位元組在後的int
*/
private static int toLH2(int in) {
int out = 0;
out = (in & 0xff) << 24;
out |= (in & 0xff00) << 8;
out |= (in & 0xff0000) >> 8;
out |= (in & 0xff000000) >> 24;
return out;
}

}

第二種 非阻試socket 客戶端、、、、、、、、、、、、、、、、、、、、、、

//首先建立連線

InetSocketAddress socketAddress = new InetSocketAddress(m_host,
10002); 

 //獲得與SelectionKey關聯的SocketChannel  

channel = SocketChannel.open(socketAddress); 

Charset charset = Charset.forName("UTF-8");// 建立GBK字符集

//將字元轉換成位元組
String firstMessage = eql + "\n\0";
String json = "";
try {
firstMessage = new String(firstMessage.getBytes(), "UTF-8");
int meslength = firstMessage.getBytes().length;

// 將長度轉換為無符號byte
byte[] b = toLH(meslength);
int count = firstMessage.getBytes().length;
byte[] buf = new byte[count + 4];
// 將長度答存入同一個byte陣列字
System.arraycopy(b, 0, buf, 0, b.length);
System.arraycopy(firstMessage.getBytes(), 0, buf, 4, count);

//傳送資料
channel.write(sendbuffer);

ByteBuffer sendbuffer = ByteBuffer.wrap(buf); 





/******* 讀取返回資料的前4個位元組 *****/
ByteBuffer length = ByteBuffer.allocate(4);
channel.read(length);
//總共位元組數
int ss = byteArrayToInt(length.array(), 0); 
 
/******* 讀取返回資料 *****/
int readlength = 1024;
ByteBuffer buffer = ByteBuffer.allocate(readlength);// 建立1024位元組的緩衝
// int byte_label = 0;
// if (ss <= readlength) {
// channel.read(buffer);
// json = new String(buffer.array(), "UTF-8");
// buffer.clear();
// } else {
// while (!(ss < readlength)) {
// channel.read(buffer);
// //System.arraycopy(buffer.array(), 0, str, byte_label,
// readlength);
// json += new String(buffer.array(), "UTF-8");
// ss = ss - readlength;
// byte_label =+ readlength;
// buffer.clear();
// }
// buffer = ByteBuffer.allocate(ss);
// channel.read(buffer);
// System.arraycopy(buffer.array(), 0, str, byte_label,
// buffer.array().length);
// json = new String(str, "UTF-8");
// channel.close();
// }

//System.out.printf("@%

//將全部位元組讀完在退出
for (int n_read = 0; n_read < ss; ) {
int n;
n = channel.read(require);
if (n < 0) {
throw new Exception();
}
n_read += n;

} 
//json = new String(require.array(), "UTF-8"); 

//將收到資料以字串展示
json = new String(require.array(),"UTF-8");
//System.out.printf(json);
//channel.close();
} catch (Exception e) {
throw new EqlException();


}