java實(shí)現(xiàn)上傳文件到服務(wù)器和客戶端
JAVA編寫一個(gè)可以上傳文件的服務(wù)器和客戶端，具體內(nèi)容如下
服務(wù)端
class Server
{
public static void main(String[] args) throws Exception
{
//建立服務(wù)端Socket
ServerSocket ss = new ServerSocket(10005);
//接收客戶端Socket
Socket fileLoaderSocket = ss.accept();
//打印連接信息
String ip = fileLoaderSocket.getInetAddress().getHostAddress();
System.out.println(ip + "...conncected");
//接收文件，并保存
InputStream in = fileLoaderSocket.getInputStream();
//實(shí)例化對(duì)象fileSave
OutputStream fileSave = new FileOutputStream("E:\\3.mp3");
//建立數(shù)組buf
byte[] buf = new byte[1024];
int len = 0;
//判斷是否讀到文件末尾
while((len=in.read(buf)) != -1)
{
fileSave.write(buf, 0, len);
//刷新
fileSave.flush();
}
//返回文件復(fù)制情況信息
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(fileLoaderSocket.getOutputStream()));
out.write("文件上傳成功");
//刷新
out.flush();
//資源關(guān)閉
ss.close();
fileLoaderSocket.close();
fileSave.close();
}
}
客戶端：
class Client
{
public static void main(String[] args) throws Exception
{
//建立Socket服務(wù)
Socket fileLoaderSocket = new Socket("168.168.168.94", 10005);
//從客戶端本地讀取文件,并寫入socket的輸出流中
OutputStream out = fileLoaderSocket.getOutputStream();
//實(shí)例化對(duì)象fileReader
InputStream fileRead = new FileInputStream("G:\\2.mp3");
//建立數(shù)組
byte[] buf = new byte[1024];
int len = 0;
//判斷是否讀到文件末尾
while((len=fileRead.read(buf)) != -1)
{
out.write(buf, 0, len);
}
//告訴服務(wù)端，文件已傳輸完畢
fileLoaderSocket.shutdownOutput();
//獲取從服務(wù)端反饋的信息
BufferedReader in = new BufferedReader(new InputStreamReader(fileLoaderSocket.getInputStream()));
String serverBack = in.readLine();
System.out.println(serverBack);
//資源關(guān)閉
fileLoaderSocket.close();
fileRead.close();
}
}
下面的程序是從別處直接照搬過(guò)來(lái)的，供學(xué)習(xí)參考：
Java Socket編程
對(duì)于Java Socket編程而言，有兩個(gè)概念，一個(gè)是ServerSocket，一個(gè)是Socket。服務(wù)端和客戶端之間通過(guò)Socket建立連接，之后它們就可以進(jìn)行通信了。首先ServerSocket將在服務(wù)端監(jiān)聽(tīng)某個(gè)端口，當(dāng)發(fā)現(xiàn)客戶端有Socket來(lái)試圖連接它時(shí)，它會(huì)accept該Socket的連接請(qǐng)求，同時(shí)在服務(wù)端建立一個(gè)對(duì)應(yīng)的Socket與之進(jìn)行通信。這樣就有兩個(gè)Socket了，客戶端和服務(wù)端各一個(gè)。
對(duì)于Socket之間的通信其實(shí)很簡(jiǎn)單，服務(wù)端往Socket的輸出流里面寫東西，客戶端就可以通過(guò)Socket的輸入流讀取對(duì)應(yīng)的內(nèi)容。Socket與Socket之間是雙向連通的，所以客戶端也可以往對(duì)應(yīng)的Socket輸出流里面寫東西，然后服務(wù)端對(duì)應(yīng)的Socket的輸入流就可以讀出對(duì)應(yīng)的內(nèi)容。下面來(lái)看一些服務(wù)端與客戶端通信的例子：
1.客戶端寫服務(wù)端讀
服務(wù)端Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//跟客戶端建立好連接之后，我們就可以獲取socket的InputStream，并從中讀取客戶端發(fā)過(guò)來(lái)的信息了。
Reader reader = new InputStreamReader(socket.getInputStream());
char chars[] = new char[64];
int len;
StringBuilder sb = new StringBuilder();
while ((len=reader.read(chars)) != -1) {
sb.append(new String(chars, 0, len));
}
System.out.println("from client: " + sb);
reader.close();
socket.close();
server.close();
}
}
服務(wù)端從Socket的InputStream中讀取數(shù)據(jù)的操作也是阻塞式的，如果從輸入流中沒(méi)有讀取到數(shù)據(jù)程序會(huì)一直在那里不動(dòng)，直到客戶端往Socket的輸出流中寫入了數(shù)據(jù)，或關(guān)閉了Socket的輸出流。當(dāng)然，對(duì)于客戶端的Socket也是同樣如此。在操作完以后，整個(gè)程序結(jié)束前記得關(guān)閉對(duì)應(yīng)的資源，即關(guān)閉對(duì)應(yīng)的IO流和Socket。
客戶端Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
writer.write("Hello Server.");
writer.flush();//寫完后要記得flush
writer.close();
client.close();
}
}
對(duì)于客戶端往Socket的輸出流里面寫數(shù)據(jù)傳遞給服務(wù)端要注意一點(diǎn)，如果寫操作之后程序不是對(duì)應(yīng)著輸出流的關(guān)閉，而是進(jìn)行其他阻塞式的操作（比如從輸入流里面讀數(shù)據(jù)），記住要flush一下，只有這樣服務(wù)端才能收到客戶端發(fā)送的數(shù)據(jù)，否則可能會(huì)引起兩邊無(wú)限的互相等待。在稍后講到客戶端和服務(wù)端同時(shí)讀和寫的時(shí)候會(huì)說(shuō)到這個(gè)問(wèn)題。
2.客戶端和服務(wù)端同時(shí)讀和寫
前面已經(jīng)說(shuō)了Socket之間是雙向通信的，它既可以接收數(shù)據(jù)，同時(shí)也可以發(fā)送數(shù)據(jù)。
服務(wù)端Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//跟客戶端建立好連接之后，我們就可以獲取socket的InputStream，并從中讀取客戶端發(fā)過(guò)來(lái)的信息了。
Reader reader = new InputStreamReader(socket.getInputStream());
char chars[] = new char[64];
int len;
StringBuilder sb = new StringBuilder();
while ((len=reader.read(chars)) != -1) {
sb.append(new String(chars, 0, len));
}
System.out.println("from client: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("Hello Client.");
writer.flush();
writer.close();
reader.close();
socket.close();
server.close();
}
}
在上述代碼中首先我們從輸入流中讀取客戶端發(fā)送過(guò)來(lái)的數(shù)據(jù)，接下來(lái)我們?cè)偻敵隽骼锩鎸懭霐?shù)據(jù)給客戶端，接下來(lái)關(guān)閉對(duì)應(yīng)的資源文件。而實(shí)際上上述代碼可能并不會(huì)按照我們預(yù)先設(shè)想的方式運(yùn)行，因?yàn)閺妮斎肓髦凶x取數(shù)據(jù)是一個(gè)阻塞式操作，在上述的while循環(huán)中當(dāng)讀到數(shù)據(jù)的時(shí)候就會(huì)執(zhí)行循環(huán)體，否則就會(huì)阻塞，這樣后面的寫操作就永遠(yuǎn)都執(zhí)行不了了。除非客戶端對(duì)應(yīng)的Socket關(guān)閉了阻塞才會(huì)停止，while循環(huán)也會(huì)跳出。針對(duì)這種可能永遠(yuǎn)無(wú)法執(zhí)行下去的情況的解決方法是while循環(huán)需要在里面有條件的跳出來(lái)，縱觀上述代碼，在不斷變化的也只有取到的長(zhǎng)度len和讀到的數(shù)據(jù)了，len已經(jīng)是不能用的了，唯一能用的就是讀到的數(shù)據(jù)了。針對(duì)這種情況，通常我們都會(huì)約定一個(gè)結(jié)束標(biāo)記，當(dāng)客戶端發(fā)送過(guò)來(lái)的數(shù)據(jù)包含某個(gè)結(jié)束標(biāo)記時(shí)就說(shuō)明當(dāng)前的數(shù)據(jù)已經(jīng)發(fā)送完畢了，這個(gè)時(shí)候我們就可以進(jìn)行循環(huán)的跳出了。那么改進(jìn)后的代碼會(huì)是這個(gè)樣子：
Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//跟客戶端建立好連接之后，我們就可以獲取socket的InputStream，并從中讀取客戶端發(fā)過(guò)來(lái)的信息了。
Reader reader = new InputStreamReader(socket.getInputStream());
char chars[] = new char[64];
int len;
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((len=reader.read(chars)) != -1) {
temp = new String(chars, 0, len);
if ((index = temp.indexOf("eof")) != -1) {//遇到eof時(shí)就結(jié)束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("from client: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("Hello Client.");
writer.flush();
writer.close();
reader.close();
socket.close();
server.close();
}
}
在上述代碼中，當(dāng)服務(wù)端讀取到客戶端發(fā)送的結(jié)束標(biāo)記，即“eof”時(shí)就會(huì)結(jié)束數(shù)據(jù)的接收，終止循環(huán)，這樣后續(xù)的代碼又可以繼續(xù)進(jìn)行了。
客戶端Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
writer.write("Hello Server.");
writer.flush();
//寫完以后進(jìn)行讀操作
Reader reader = new InputStreamReader(client.getInputStream());
char chars[] = new char[64];
int len;
StringBuffer sb = new StringBuffer();
while ((len=reader.read(chars)) != -1) {
sb.append(new String(chars, 0, len));
}
System.out.println("from server: " + sb);
writer.close();
reader.close();
client.close();
}
}
在上述代碼中我們先是給服務(wù)端發(fā)送了一段數(shù)據(jù)，之后讀取服務(wù)端返回來(lái)的數(shù)據(jù)，跟之前的服務(wù)端一樣在讀的過(guò)程中有可能導(dǎo)致程序一直掛在那里，永遠(yuǎn)跳不出while循環(huán)。這段代碼配合服務(wù)端的第一段代碼就正好讓我們分析服務(wù)端永遠(yuǎn)在那里接收數(shù)據(jù)，永遠(yuǎn)跳不出while循環(huán)，也就沒(méi)有之后的服務(wù)端返回?cái)?shù)據(jù)給客戶端，客戶端也就不可能接收到服務(wù)端返回的數(shù)據(jù)。解決方法如服務(wù)端第二段代碼所示，在客戶端發(fā)送數(shù)據(jù)完畢后，往輸出流里面寫入結(jié)束標(biāo)記告訴服務(wù)端數(shù)據(jù)已經(jīng)發(fā)送完畢了，同樣服務(wù)端返回?cái)?shù)據(jù)完畢后也發(fā)一個(gè)標(biāo)記告訴客戶端。那么修改后的客戶端代碼就應(yīng)該是這個(gè)樣子：
Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
writer.write("Hello Server.");
writer.write("eof");
writer.flush();
//寫完以后進(jìn)行讀操作
Reader reader = new InputStreamReader(client.getInputStream());
char chars[] = new char[64];
int len;
StringBuffer sb = new StringBuffer();
String temp;
int index;
while ((len=reader.read(chars)) != -1) {
temp = new String(chars, 0, len);
if ((index = temp.indexOf("eof")) != -1) {
sb.append(temp.substring(0, index));
break;
}
sb.append(new String(chars, 0, len));
}
System.out.println("from server: " + sb);
writer.close();
reader.close();
client.close();
}
}
我們?nèi)粘Ｊ褂玫谋容^多的都是這種客戶端發(fā)送數(shù)據(jù)給服務(wù)端，服務(wù)端接收數(shù)據(jù)后再返回相應(yīng)的結(jié)果給客戶端這種形式。只是客戶端和服務(wù)端之間不再是這種一對(duì)一的關(guān)系，而是下面要講到的多個(gè)客戶端對(duì)應(yīng)同一個(gè)服務(wù)端的情況。
3.多個(gè)客戶端連接同一個(gè)服務(wù)端
像前面講的兩個(gè)例子都是服務(wù)端接收一個(gè)客戶端的請(qǐng)求之后就結(jié)束了，不能再接收其他客戶端的請(qǐng)求了，這往往是不能滿足我們的要求的。通常我們會(huì)這樣做：
Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
while (true) {
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//跟客戶端建立好連接之后，我們就可以獲取socket的InputStream，并從中讀取客戶端發(fā)過(guò)來(lái)的信息了。
Reader reader = new InputStreamReader(socket.getInputStream());
char chars[] = new char[64];
int len;
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((len=reader.read(chars)) != -1) {
temp = new String(chars, 0, len);
if ((index = temp.indexOf("eof")) != -1) {//遇到eof時(shí)就結(jié)束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("from client: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("Hello Client.");
writer.flush();
writer.close();
reader.close();
socket.close();
}
}
}
在上面代碼中我們用了一個(gè)死循環(huán)，在循環(huán)體里面ServerSocket調(diào)用其accept方法試圖接收來(lái)自客戶端的連接請(qǐng)求。當(dāng)沒(méi)有接收到請(qǐng)求的時(shí)候，程序會(huì)在這里阻塞直到接收到來(lái)自客戶端的連接請(qǐng)求，之后會(huì)跟當(dāng)前建立好連接的客戶端進(jìn)行通信，完了后會(huì)接著執(zhí)行循環(huán)體再次嘗試接收新的連接請(qǐng)求。這樣我們的ServerSocket就能接收來(lái)自所有客戶端的連接請(qǐng)求了，并且與它們進(jìn)行通信了。這就實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的一個(gè)服務(wù)端與多個(gè)客戶端進(jìn)行通信的模式。
上述例子中雖然實(shí)現(xiàn)了一個(gè)服務(wù)端跟多個(gè)客戶端進(jìn)行通信，但是還存在一個(gè)問(wèn)題。在上述例子中，我們的服務(wù)端處理客戶端的連接請(qǐng)求是同步進(jìn)行的，每次接收到來(lái)自客戶端的連接請(qǐng)求后，都要先跟當(dāng)前的客戶端通信完之后才能再處理下一個(gè)連接請(qǐng)求。這在并發(fā)比較多的情況下會(huì)嚴(yán)重影響程序的性能，為此，我們可以把它改為如下這種異步處理與客戶端通信的方式：
Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
while (true) {
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//每接收到一個(gè)Socket就建立一個(gè)新的線程來(lái)處理它
new Thread(new Task(socket)).start();
}
}
/**
* 用來(lái)處理Socket請(qǐng)求的
*/
static class Task implements Runnable {
private Socket socket;
public Task(Socket socket) {
this.socket = socket;
}
public void run() {
try {
handleSocket();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 跟客戶端Socket進(jìn)行通信
* @throws Exception
*/
private void handleSocket() throws Exception {
Reader reader = new InputStreamReader(socket.getInputStream());
char chars[] = new char[64];
int len;
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((len=reader.read(chars)) != -1) {
temp = new String(chars, 0, len);
if ((index = temp.indexOf("eof")) != -1) {//遇到eof時(shí)就結(jié)束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("from client: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("Hello Client.");
writer.flush();
writer.close();
reader.close();
socket.close();
}
}
}
在上面代碼中，每次ServerSocket接收到一個(gè)新的Socket連接請(qǐng)求后都會(huì)新起一個(gè)線程來(lái)跟當(dāng)前Socket進(jìn)行通信，這樣就達(dá)到了異步處理與客戶端Socket進(jìn)行通信的情況。
在從Socket的InputStream中接收數(shù)據(jù)時(shí)，像上面那樣一點(diǎn)點(diǎn)的讀就太復(fù)雜了，有時(shí)候我們就會(huì)換成使用BufferedReader來(lái)一次讀一行，如：
Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
while (true) {
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//每接收到一個(gè)Socket就建立一個(gè)新的線程來(lái)處理它
new Thread(new Task(socket)).start();
}
}
/**
* 用來(lái)處理Socket請(qǐng)求的
*/
static class Task implements Runnable {
private Socket socket;
public Task(Socket socket) {
this.socket = socket;
}
public void run() {
try {
handleSocket();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 跟客戶端Socket進(jìn)行通信
* @throws Exception
*/
private void handleSocket() throws Exception {
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((temp=br.readLine()) != null) {
System.out.println(temp);
if ((index = temp.indexOf("eof")) != -1) {//遇到eof時(shí)就結(jié)束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("from client: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("Hello Client.");
writer.write("eof\n");
writer.flush();
writer.close();
br.close();
socket.close();
}
}
}
這個(gè)時(shí)候需要注意的是，BufferedReader的readLine方法是一次讀一行的，這個(gè)方法是阻塞的，直到它讀到了一行數(shù)據(jù)為止程序才會(huì)繼續(xù)往下執(zhí)行，那么readLine什么時(shí)候才會(huì)讀到一行呢？直到程序遇到了換行符或者是對(duì)應(yīng)流的結(jié)束符readLine方法才會(huì)認(rèn)為讀到了一行，才會(huì)結(jié)束其阻塞，讓程序繼續(xù)往下執(zhí)行。所以我們?cè)谑褂肂ufferedReader的readLine讀取數(shù)據(jù)的時(shí)候一定要記得在對(duì)應(yīng)的輸出流里面一定要寫入換行符（流結(jié)束之后會(huì)自動(dòng)標(biāo)記為結(jié)束，readLine可以識(shí)別），寫入換行符之后一定記得如果輸出流不是馬上關(guān)閉的情況下記得flush一下，這樣數(shù)據(jù)才會(huì)真正的從緩沖區(qū)里面寫入。對(duì)應(yīng)上面的代碼我們的客戶端程序應(yīng)該這樣寫：
Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
writer.write("Hello Server.");
writer.write("eof\n");
writer.flush();
//寫完以后進(jìn)行讀操作
BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
StringBuffer sb = new StringBuffer();
String temp;
int index;
while ((temp=br.readLine()) != null) {
if ((index = temp.indexOf("eof")) != -1) {
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("from server: " + sb);
writer.close();
br.close();
client.close();
}
}
4.設(shè)置超時(shí)時(shí)間
假設(shè)有這樣一種需求，我們的客戶端需要通過(guò)Socket從服務(wù)端獲取到XX信息，然后給用戶展示在頁(yè)面上。我們知道Socket在讀數(shù)據(jù)的時(shí)候是阻塞式的，如果沒(méi)有讀到數(shù)據(jù)程序會(huì)一直阻塞在那里。在同步請(qǐng)求的時(shí)候我們肯定是不能允許這樣的情況發(fā)生的，這就需要我們?cè)谡?qǐng)求達(dá)到一定的時(shí)間后控制阻塞的中斷，讓程序得以繼續(xù)運(yùn)行。Socket為我們提供了一個(gè)setSoTimeout()方法來(lái)設(shè)置接收數(shù)據(jù)的超時(shí)時(shí)間，單位是毫秒。當(dāng)設(shè)置的超時(shí)時(shí)間大于0，并且超過(guò)了這一時(shí)間Socket還沒(méi)有接收到返回的數(shù)據(jù)的話，Socket就會(huì)拋出一個(gè)SocketTimeoutException。
假設(shè)我們需要控制我們的客戶端在開(kāi)始讀取數(shù)據(jù)10秒后還沒(méi)有讀到數(shù)據(jù)就中斷阻塞的話我們可以這樣做：
Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
writer.write("Hello Server.");
writer.write("eof\n");
writer.flush();
//寫完以后進(jìn)行讀操作
BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
//設(shè)置超時(shí)間為10秒
client.setSoTimeout(10*1000);
StringBuffer sb = new StringBuffer();
String temp;
int index;
try {
while ((temp=br.readLine()) != null) {
if ((index = temp.indexOf("eof")) != -1) {
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
} catch (SocketTimeoutException e) {
System.out.println("數(shù)據(jù)讀取超時(shí)。");
}
System.out.println("from server: " + sb);
writer.close();
br.close();
client.close();
}
}
5.接收數(shù)據(jù)亂碼
對(duì)于這種服務(wù)端或客戶端接收中文亂碼的情況通常是因?yàn)閿?shù)據(jù)發(fā)送時(shí)使用的編碼跟接收時(shí)候使用的編碼不一致。比如有下面這樣一段服務(wù)端代碼：
Java代碼
public class Server {
public static void main(String args[]) throws IOException {
//為了簡(jiǎn)單起見(jiàn)，所有的異常信息都往外拋
int port = 8899;
//定義一個(gè)ServerSocket監(jiān)聽(tīng)在端口8899上
ServerSocket server = new ServerSocket(port);
while (true) {
//server嘗試接收其他Socket的連接請(qǐng)求，server的accept方法是阻塞式的
Socket socket = server.accept();
//每接收到一個(gè)Socket就建立一個(gè)新的線程來(lái)處理它
new Thread(new Task(socket)).start();
}
}
/**
* 用來(lái)處理Socket請(qǐng)求的
*/
static class Task implements Runnable {
private Socket socket;
public Task(Socket socket) {
this.socket = socket;
}
public void run() {
try {
handleSocket();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 跟客戶端Socket進(jìn)行通信
* @throws Exception
*/
private void handleSocket() throws Exception {
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK"));
StringBuilder sb = new StringBuilder();
String temp;
int index;
while ((temp=br.readLine()) != null) {
System.out.println(temp);
if ((index = temp.indexOf("eof")) != -1) {//遇到eof時(shí)就結(jié)束接收
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
System.out.println("客戶端: " + sb);
//讀完后寫一句
Writer writer = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");
writer.write("你好，客戶端。");
writer.write("eof\n");
writer.flush();
writer.close();
br.close();
socket.close();
}
}
}
這里用來(lái)測(cè)試我就弄的混亂了一點(diǎn)。在上面服務(wù)端代碼中我們?cè)诙x輸入流的時(shí)候明確定義了使用GBK編碼來(lái)讀取數(shù)據(jù)，而在定義輸出流的時(shí)候明確指定了將使用UTF-8編碼來(lái)發(fā)送數(shù)據(jù)。如果客戶端上送數(shù)據(jù)的時(shí)候不以GBK編碼來(lái)發(fā)送的話服務(wù)端接收的數(shù)據(jù)就很有可能會(huì)亂碼；同樣如果客戶端接收數(shù)據(jù)的時(shí)候不以服務(wù)端發(fā)送數(shù)據(jù)的編碼，即UTF-8編碼來(lái)接收數(shù)據(jù)的話也極有可能會(huì)出現(xiàn)數(shù)據(jù)亂碼的情況。所以，對(duì)于上述服務(wù)端代碼，為使我們的程序能夠讀取對(duì)方發(fā)送過(guò)來(lái)的數(shù)據(jù)，而不出現(xiàn)亂碼情況，我們的客戶端應(yīng)該是這樣的：
Java代碼
public class Client {
public static void main(String args[]) throws Exception {
//為了簡(jiǎn)單起見(jiàn)，所有的異常都直接往外拋
String host = "127.0.0.1"; //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對(duì)應(yīng)的監(jiān)聽(tīng)端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
//建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream(), "GBK");
writer.write("你好，服務(wù)端。");
writer.write("eof\n");
writer.flush();
//寫完以后進(jìn)行讀操作
BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream(), "UTF-8"));
//設(shè)置超時(shí)間為10秒
client.setSoTimeout(10*1000);
StringBuffer sb = new StringBuffer();
String temp;
int index;
try {
while ((temp=br.readLine()) != null) {
if ((index = temp.indexOf("eof")) != -1) {
sb.append(temp.substring(0, index));
break;
}
sb.append(temp);
}
} catch (SocketTimeoutException e) {
System.out.println("數(shù)據(jù)讀取超時(shí)。");
}
System.out.println("服務(wù)端: " + sb);
writer.close();
br.close();
client.close();
}
}
本文已被整理到了《Java上傳操作技巧匯總》，歡迎大家學(xué)習(xí)閱讀。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
- Java實(shí)現(xiàn)圖片上傳到服務(wù)器并把上傳的圖片讀取出來(lái)
- JAVA技術(shù)實(shí)現(xiàn)上傳下載文件到FTP服務(wù)器(完整)
- Java實(shí)現(xiàn)文件上傳至服務(wù)器的方法
- Java實(shí)現(xiàn)上傳文件圖片到指定服務(wù)器目錄
- 基于HTML5+js+Java實(shí)現(xiàn)單文件文件上傳到服務(wù)器功能
- Java通過(guò)FTP服務(wù)器上傳下載文件的方法
- Java實(shí)現(xiàn)跨服務(wù)器上傳文件功能
- Android實(shí)現(xiàn)上傳圖片至java服務(wù)器
- Java如何實(shí)現(xiàn)上傳文件到服務(wù)器指定目錄
- java實(shí)現(xiàn)文件上傳到服務(wù)器
相關(guān)文章
Java.io?包幾乎包含了所有操作輸入、輸出需要的類。所有這些流類代表了輸入源和輸出目標(biāo)。本文將通過(guò)示例為大家詳細(xì)講講?I/O流的使用教程，需要的可以參考一下2022-08-08
springmvc學(xué)習(xí)筆記-返回json的日期格式問(wèn)題的解決方法
本篇文章主要介紹了springmvc學(xué)習(xí)筆記-返回json的日期格式問(wèn)題的解決方法，解決了日期格式的輸出，有興趣的可以了解一下。2017-01-01
這篇文章主要介紹了詳解Java中類與對(duì)象的關(guān)系,類的關(guān)鍵字是class，在Java編程里，類的作用相當(dāng)于機(jī)械師手中的構(gòu)造圖，如果沒(méi)有構(gòu)造圖，就無(wú)法打造武器，同樣如果沒(méi)有類，就無(wú)法實(shí)例化,需要的朋友可以參考下2023-05-05
這篇文章主要介紹了Mybatisplus主鍵生成策略算法解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-11-11
詳解Spring 基于 Aspect 注解的增強(qiáng)實(shí)現(xiàn)
本篇文章主要介紹了詳解Spring 基于 Aspect 注解的增強(qiáng)實(shí)現(xiàn)，非常具有實(shí)用價(jià)值，需要的朋友可以參考下2017-04-04
SpringBoot環(huán)境配置知識(shí)總結(jié)
今天帶大家了解SpringBoot環(huán)境配置的相關(guān)知識(shí),文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java的小伙伴們有很好地幫助,需要的朋友可以參考下2021-05-05
Java實(shí)現(xiàn)將Object轉(zhuǎn)成List的五種方法
在Java中,將一個(gè)Object轉(zhuǎn)換為L(zhǎng)ist是一個(gè)常見(jiàn)的需求,尤其是在處理集合操作和數(shù)據(jù)轉(zhuǎn)換時(shí),本文將詳細(xì)討論如何實(shí)現(xiàn)這一轉(zhuǎn)換,并提供一些代碼示例,需要的朋友可以參考下2025-03-03
SpringBoot整合Druid數(shù)據(jù)源過(guò)程詳解
這篇文章主要介紹了SpringBoot整合Druid數(shù)據(jù)源過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了Java 解決讀寫本地文件中文亂碼的問(wèn)題的相關(guān)資料,需要的朋友可以參考下2017-01-01
本文主要介紹了SpringMVC配置404踩坑記錄，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-03-03