socket上傳文件java

A. 關於用java的SOCKET傳輸文件

點對點傳輸文件
/*
import java.io.*;
import java.net.*;
import java.util.*;
*/
private HttpURLConnection connection;//存儲連接
private int downsize = -1;//下載文件大小,初始值為-1
private int downed = 0;//文加已下載大小,初始值為0
private RandomAccessFile savefile;//記錄下載信息存儲文件
private URL fileurl;//記錄要下載文件的地址
private DataInputStream fileStream;//記錄下載的數據流
try{
/*開始創建下載的存儲文件,並初始化值*/
File tempfileobject = new File("h:\\webwork-2.1.7.zip");
if(!tempfileobject.exists()){
/*文件不存在則建立*/
tempfileobject.createNewFile();
}
savefile = new RandomAccessFile(tempfileobject,"rw");

/*建立連接*/
fileurl = new URL("https://webwork.dev.java.net/files/documents/693/9723/webwork-2.1.7.zip");
connection = (HttpURLConnection)fileurl.openConnection();
connection.setRequestProperty("Range","byte="+this.downed+"-");

this.downsize = connection.getContentLength();
//System.out.println(connection.getContentLength());

new Thread(this).start();
}
catch(Exception e){
System.out.println(e.toString());
System.out.println("構建器錯誤");
System.exit(0);
}
public void run(){
/*開始下載文件,以下測試非斷點續傳,下載的文件存在問題*/
try{
System.out.println("begin!");
Date begintime = new Date();
begintime.setTime(new Date().getTime());
byte[] filebyte;
int onecelen;
//System.out.println(this.connection.getInputStream().getClass().getName());
this.fileStream = new DataInputStream(
new BufferedInputStream(
this.connection.getInputStream()));
System.out.println("size = " + this.downsize);
while(this.downsize != this.downed){
if(this.downsize - this.downed > 262144){//設置為最大256KB的緩存
filebyte = new byte[262144];
onecelen = 262144;
}
else{
filebyte = new byte[this.downsize - this.downed];
onecelen = this.downsize - this.downed;
}
onecelen = this.fileStream.read(filebyte,0,onecelen);
this.savefile.write(filebyte,0,onecelen);
this.downed += onecelen;
System.out.println(this.downed);
}
this.savefile.close();
System.out.println("end!");
System.out.println(begintime.getTime());
System.out.println(new Date().getTime());
System.out.println(begintime.getTime() - new Date().getTime());
}
catch(Exception e){
System.out.println(e.toString());
System.out.println("run()方法有問題!");
}
}

/***
//FileClient.java
import java.io.*;
import java.net.*;
public class FileClient {
public static void main(String[] args) throws Exception {

//使用本地文件系統接受網路數據並存為新文件

File file = new File("d:\\fmd.doc");

file.createNewFile();

RandomAccessFile raf = new RandomAccessFile(file, "rw");

// 通過Socket連接文件伺服器

Socket server = new Socket(InetAddress.getLocalHost(), 3318);
//創建網路接受流接受伺服器文件數據
InputStream netIn = server.getInputStream();
InputStream in = new DataInputStream(new BufferedInputStream(netIn));
//創建緩沖區緩沖網路數據

byte[] buf = new byte[2048];

int num = in.read(buf);

while (num != (-1)) {//是否讀完所有數據

raf.write(buf, 0, num);//將數據寫往文件

raf.skipBytes(num);//順序寫文件位元組

num = in.read(buf);//繼續從網路中讀取文件

}
in.close();
raf.close();
}
}

//FileServer.java
import java.io.*;
import java.util.*;
import java.net.*;
public class FileServer {
public static void main(String[] args) throws Exception {

//創建文件流用來讀取文件中的數據

File file = new File("d:\\系統特點.doc");

FileInputStream fos = new FileInputStream(file);

//創建網路伺服器接受客戶請求

ServerSocket ss = new ServerSocket(8801);

Socket client = ss.accept();

//創建網路輸出流並提供數據包裝器

OutputStream netOut = client.getOutputStream();

OutputStream doc = new DataOutputStream(
new BufferedOutputStream(netOut));

//創建文件讀取緩沖區

byte[] buf = new byte[2048];

int num = fos.read(buf);
while (num != (-1)) {//是否讀完文件
doc.write(buf, 0, num);//把文件數據寫出網路緩沖區
doc.flush();//刷新緩沖區把數據寫往客戶端
num = fos.read(buf);//繼續從文件中讀取數據
}
fos.close();
doc.close();
}
}
*/

B. JAVA socket傳輸二進制文件問題

可能LZ對使用瀏覽器進行用戶名密碼認證比較清楚
SOCKET走的是TCP/IP協議，而瀏覽器方式走的是HTTP協議
不管哪種方式，都是通過客戶端程序上發到伺服器端，而瀏覽器方式的通道都是默認OK的，而TCP方式則需要通過SOCKET來建立通道，傳輸的數據是通過報文格式，報文你可以理解是一串東東，這個東東可以是二進制，可以是十進制，可以是字元串
對於進行用戶名密碼認證，你看成是字元串就行了
根據客戶端和服務端規定好的報文格式進行解析，驗證的工作和HTTP協議的方式一樣，簡單來說就是放在servlet上進行。
區別就是，SOCKET要自己建立連接以及自己制定報文格式，而瀏覽器方式只要通過request方式傳送就OK了

C. 網上的Java基於Socket文件傳輸示例，一個客戶端一個伺服器端一個socket的Util輔助類怎麼運行起來啊

伺服器（Server）

[java] view plain
package com.socket.sample;

import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerTest {
int port = 8821;

void start() {
Socket s = null;
try {
ServerSocket ss = new ServerSocket(port);
while (true) {
// 選擇進行傳輸的文件
String filePath = "D:\\lib.rar";
File fi = new File(filePath);

System.out.println("文件長度:" + (int) fi.length());

// public Socket accept() throws
// IOException偵聽並接受到此套接字的連接。此方法在進行連接之前一直阻塞。

s = ss.accept();
System.out.println("建立socket鏈接");
DataInputStream dis = new DataInputStream(
new BufferedInputStream(s.getInputStream()));
dis.readByte();

DataInputStream fis = new DataInputStream(
new BufferedInputStream(new FileInputStream(filePath)));
DataOutputStream ps = new DataOutputStream(s.getOutputStream());
// 將文件名及長度傳給客戶端。這里要真正適用所有平台，例如中文名的處理，還需要加工，具體可以參見Think In Java
// 4th里有現成的代碼。
ps.writeUTF(fi.getName());
ps.flush();
ps.writeLong((long) fi.length());
ps.flush();

int bufferSize = 8192;
byte[] buf = new byte[bufferSize];

while (true) {
int read = 0;
if (fis != null) {
read = fis.read(buf);
// 從包含的輸入流中讀取一定數量的位元組，並將它們存儲到緩沖區數組 b
// 中。以整數形式返回實際讀取的位元組數。在輸入數據可用、檢測到文件末尾 (end of file)
// 或拋出異常之前，此方法將一直阻塞。
}

if (read == -1) {
break;
}
ps.write(buf, 0, read);
}
ps.flush();
// 注意關閉socket鏈接哦，不然客戶端會等待server的數據過來，
// 直到socket超時，導致數據不完整。
fis.close();
s.close();
System.out.println("文件傳輸完成");
}

} catch (Exception e) {
e.printStackTrace();
}
}

public static void main(String arg[]) {
new ServerTest().start();
}
}
客戶端工具（SocketTool）
[java] view plain
package com.socket.sample;

import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;

public class ClientSocket {
private String ip;

private int port;

private Socket socket = null;

DataOutputStream out = null;

DataInputStream getMessageStream = null;

public ClientSocket(String ip, int port) {
this.ip = ip;
this.port = port;
}

/** */
/**
* 創建socket連接
*
* @throws Exception
* exception
*/
public void CreateConnection() throws Exception {
try {
socket = new Socket(ip, port);
} catch (Exception e) {
e.printStackTrace();
if (socket != null)
socket.close();
throw e;
} finally {
}
}

public void sendMessage(String sendMessage) throws Exception {
try {
out = new DataOutputStream(socket.getOutputStream());
if (sendMessage.equals("Windows")) {
out.writeByte(0x1);
out.flush();
return;
}
if (sendMessage.equals("Unix")) {
out.writeByte(0x2);
out.flush();
return;
}
if (sendMessage.equals("Linux")) {
out.writeByte(0x3);
out.flush();
} else {
out.writeUTF(sendMessage);
out.flush();
}
} catch (Exception e) {
e.printStackTrace();
if (out != null)
out.close();
throw e;
} finally {
}
}

public DataInputStream getMessageStream() throws Exception {
try {
getMessageStream = new DataInputStream(new BufferedInputStream(
socket.getInputStream()));
return getMessageStream;
} catch (Exception e) {
e.printStackTrace();
if (getMessageStream != null)
getMessageStream.close();
throw e;
} finally {
}
}

public void shutDownConnection() {
try {
if (out != null)
out.close();
if (getMessageStream != null)
getMessageStream.close();
if (socket != null)
socket.close();
} catch (Exception e) {

}
}
}

客戶端（Client）

[java] view plain
package com.socket.sample;

import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;

public class ClientTest {
private ClientSocket cs = null;

private String ip = "localhost";// 設置成伺服器IP

private int port = 8821;

private String sendMessage = "Windows";

public ClientTest() {
try {
if (createConnection()) {
sendMessage();
getMessage();
}

} catch (Exception ex) {
ex.printStackTrace();
}
}

private boolean createConnection() {
cs = new ClientSocket(ip, port);
try {
cs.CreateConnection();
System.out.print("連接伺服器成功!" + "\n");
return true;
} catch (Exception e) {
System.out.print("連接伺服器失敗!" + "\n");
return false;
}

}

private void sendMessage() {
if (cs == null)
return;
try {
cs.sendMessage(sendMessage);
} catch (Exception e) {
System.out.print("發送消息失敗!" + "\n");
}
}

private void getMessage() {
if (cs == null)
return;
DataInputStream inputStream = null;
try {
inputStream = cs.getMessageStream();
} catch (Exception e) {
System.out.print("接收消息緩存錯誤\n");
return;
}

try {
// 本地保存路徑，文件名會自動從伺服器端繼承而來。
String savePath = "E:\\";
int bufferSize = 8192;
byte[] buf = new byte[bufferSize];
int passedlen = 0;
long len = 0;

savePath += inputStream.readUTF();
DataOutputStream fileOut = new DataOutputStream(
new BufferedOutputStream(new FileOutputStream(savePath)));
len = inputStream.readLong();

System.out.println("文件的長度為:" + len + "\n");
System.out.println("開始接收文件!" + "\n");

while (true) {
int read = 0;
if (inputStream != null) {
read = inputStream.read(buf);
}
passedlen += read;
if (read == -1) {
break;
}
// 下面進度條本為圖形界面的prograssBar做的，這里如果是打文件，可能會重復列印出一些相同的百分比
System.out.println("文件接收了" + (passedlen * 100 / len) + "%\n");
fileOut.write(buf, 0, read);
}
System.out.println("接收完成，文件存為" + savePath + "\n");

fileOut.close();
} catch (Exception e) {
System.out.println("接收消息錯誤" + "\n");
return;
}
}

public static void main(String arg[]) {
new ClientTest().getMessage();
}
}

測試是成功的，在DOS命令行下編譯~~~

D. java socket傳送文件怎麼設置傳送速度，比如一個文件100M，每次傳送1024BYTE

你發送(和接受)的時候,每次發1024位元組就可以啦

E. JAVA socket傳送文件一直被阻塞

是不能等於來-1撒..

他在等你那邊源給他寫東西呢..

你應該在伺服器端結束的時候給他寫個東西過去..讓他知道已經結束了..

還有什麼問題HI我哈

但是read方法本身不就有告知客戶端文件傳送結束的功能么 當讀到文件結束符的時候它會返回-1的啊

確實讀文件結束就是-1...
但是你的客戶端讀的不是文件啊..伺服器才是讀文件..所以伺服器能正常結束..
你的客戶端讀的伺服器發來的東西..伺服器讀文件結束後就不給客戶端發信息了..
而客戶端的read()方法是阻塞式方法..意思就是伺服器不傳給他數據他就會一直等..

所以還是那樣..在伺服器端結束的時候給客戶端發個消息說明已經結束了..客戶端讀到這個結束標志的時候也就不要再往文件裡面寫東西了..也結束..這樣你的程序就正確了..

F. java中,利用socket傳送大文件,中途停止問題

thread裡面接收數據應該是一個循環把？
那麼就給這個循環加一個跳出條件，比如說版
private boolean stop=true;

在循環當中增加權
if(stop=false){
break;

}
public void setStop(boolean stop)
{
this.stop=stop;

}
然後在需要停的時候調用setStop(false)就可以了
上面純手打，代碼拼寫什麼的可能有錯大概就是這個意思
順便說一下，thread.interrupt()是用來防止sleep或者wait方法卡死的，不會讓線程終結。你要讓線程結束還是要手動讓程序跳出循環

G. 在Android端使用socket傳輸圖片到java伺服器，求源代碼

/**
*思想：
1.直接將所有數據安裝位元組數組發送
2.對象序列化方式
*/

/**
*thread方式
*
*@authorAdministrator
*/
{
privatestaticfinalintFINISH=0;
privateButtonsend=null;
privateTextViewinfo=null;
privateHandlermyHandler=newHandler(){
@Override
publicvoidhandleMessage(Messagemsg){
switch(msg.what){
caseFINISH:
Stringresult=msg.obj.toString();//取出數據
if("true".equals(result)){
TestSocketActivity4.this.info.setText("操作成功！");
}else{
TestSocketActivity4.this.info.setText("操作失敗！");
}
break;
}
}
};


@Override
publicvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
super.setContentView(R.layout.activity_test_sokect_activity4);
//StrictMode.setThreadPolicy(newStrictMode.ThreadPolicy.Builder()
//.detectDiskReads().detectDiskWrites().detectNetwork()
//.penaltyLog().build());
//StrictMode.setVmPolicy(newStrictMode.VmPolicy.Builder()
//.detectLeakedSqlLiteObjects().detectLeakedClosableObjects()
//.penaltyLog().penaltyDeath().build());

this.send=(Button)super.findViewById(R.id.send);
this.info=(TextView)super.findViewById(R.id.info);
this.send.setOnClickListener(newSendOnClickListener());
}

{
@Override
publicvoidonClick(Viewv){
try{
newThread(newRunnable(){
@Override
publicvoidrun(){
try{
//1:
Socketclient=newSocket("192.168.1.165",9898);
//2:
ObjectOutputStreamoos=newObjectOutputStream(
client.getOutputStream());
//3:
UploadFilemyFile=SendOnClickListener.this
.getUploadFile();
//4:
oos.writeObject(myFile);//寫文件對象
//oos.writeObject(null);//避免EOFException
oos.close();


BufferedReaderbuf=newBufferedReader(
newInputStreamReader(client
.getInputStream()));//讀取返回的數據
Stringstr=buf.readLine();//讀取數據
Messagemsg=TestSocketActivity4.this.myHandler
.obtainMessage(FINISH,str);
TestSocketActivity4.this.myHandler.sendMessage(msg);
buf.close();
client.close();
}catch(Exceptione){
Log.i("UploadFile",e.getMessage());
}
}
}).start();
}catch(Exceptione){
e.printStackTrace();
}
}

()throwsException{//包裝了傳送數據
UploadFilemyFile=newUploadFile();
myFile.setTitle("tangcco安卓之Socket的通信");//設置標題
myFile.setMimeType("image/png");//圖片的類型
Filefile=newFile(Environment.getExternalStorageDirectory()
.toString()
+File.separator
+"Pictures"
+File.separator
+"b.png");
InputStreaminput=null;
try{
input=newFileInputStream(file);//從文件中讀取
ByteArrayOutputStreambos=newByteArrayOutputStream();
bytedata[]=newbyte[1024];
intlen=0;
while((len=input.read(data))!=-1){
bos.write(data,0,len);
}
myFile.setContentData(bos.toByteArray());
myFile.setContentLength(file.length());
myFile.setExt("png");
}catch(Exceptione){
throwe;
}finally{
input.close();
}
returnmyFile;
}
}

}{
	privateStringtitle;
	privatebyte[]contentData;
	privateStringmimeType;
	privatelongcontentLength;
	privateStringext;

	publicStringgetTitle(){
		returntitle;
	}

	publicvoidsetTitle(Stringtitle){
		this.title=title;
	}

	publicbyte[]getContentData(){
		returncontentData;
	}

	publicvoidsetContentData(byte[]contentData){
		this.contentData=contentData;
	}

	publicStringgetMimeType(){
		returnmimeType;
	}

	publicvoidsetMimeType(StringmimeType){
		this.mimeType=mimeType;
	}

	publiclonggetContentLength(){
		returncontentLength;
	}

	publicvoidsetContentLength(longcontentLength){
		this.contentLength=contentLength;
	}

	publicStringgetExt(){
		returnext;
	}

	publicvoidsetExt(Stringext){
		this.ext=ext;
	}

}

下邊是服務端

publicclassMain4{
	publicstaticvoidmain(String[]args)throwsException{
		ServerSocketserver=newServerSocket(9898);//伺服器端埠
		System.out.println("服務啟動........................");
		booleanflag=true;//定義標記，可以一直死循環
		while(flag){//通過標記判斷循環
			newThread(newServerThreadUtil(server.accept())).start();//啟動線程
		}
		server.close();//關閉伺服器
	}
}


{
	="D:"+File.separator+"myfile"
			+File.separator;//目錄路徑
	privateSocketclient=null;
	privateUploadFileupload=null;

	publicServerThreadUtil(Socketclient){
		this.client=client;
		System.out.println("新的客戶端連接...");
	}

	@Override
	publicvoidrun(){
		try{
			ObjectInputStreamois=newObjectInputStream(
					client.getInputStream());//反序列化
			this.upload=(UploadFile)ois.readObject();//讀取對象//UploadFile需要和客戶端傳遞過來的包名類名相同，如果不同則會報異常
			System.out.println("文件標題："+this.upload.getTitle());
			System.out.println("文件類型："+this.upload.getMimeType());
			System.out.println("文件大小："+this.upload.getContentLength());
			
			PrintStreamout=newPrintStream(this.client.getOutputStream());//BufferedWriter
			out.print(this.saveFile());//返回響應
//			BufferedWriterwriter=null;
//			writer.write("");
		}catch(Exceptione){
			e.printStackTrace();
		}finally{
			try{
				this.client.close();
			}catch(IOExceptione){
				e.printStackTrace();
			}
		}
	}

	privatebooleansaveFile()throwsException{//負責文件內容的保存
		/**
		*java.util.UUID.randomUUID():
		*UUID.randomUUID().toString()是javaJDK提供的一個自動生成主鍵的方法。UUID(Universally
		*UniqueIdentifier)全局唯一標識符,是指在一台機器上生成的數字，它保證對在同一時空中的所有機器都是唯一的，
		*是由一個十六位的數字組成
		*,表現出來的形式。由以下幾部分的組合：當前日期和時間(UUID的第一個部分與時間有關，如果你在生成一個UUID之後，
		*過幾秒又生成一個UUID，
		*則第一個部分不同，其餘相同)，時鍾序列，全局唯一的IEEE機器識別號（如果有網卡，從網卡獲得，沒有網卡以其他方式獲得
		*），UUID的唯一缺陷在於生成的結果串會比較長，字元串長度為36。
		*
		*UUID.randomUUID().toString()是javaJDK提供的一個自動生成主鍵的方法。UUID(Universally
		*UniqueIdentifier)全局唯一標識符,是指在一台機器上生成的數字，它保證對在同一時空中的所有機器都是唯一的，
		*是由一個十六位的數字組成,表現出來的形式
		*/
		Filefile=newFile(DIRPATH+UUID.randomUUID()+"."
				+this.upload.getExt());
		if(!file.getParentFile().exists()){
			file.getParentFile().mkdir();
		}
		OutputStreamoutput=null;
		try{
			output=newFileOutputStream(file);
			output.write(this.upload.getContentData());
			returntrue;
		}catch(Exceptione){
			throwe;
		}finally{
			output.close();
		}
	}
}{
	privateStringtitle;
	privatebyte[]contentData;
	privateStringmimeType;
	privatelongcontentLength;
	privateStringext;

	publicStringgetTitle(){
		returntitle;
	}

	publicvoidsetTitle(Stringtitle){
		this.title=title;
	}

	publicbyte[]getContentData(){
		returncontentData;
	}

	publicvoidsetContentData(byte[]contentData){
		this.contentData=contentData;
	}

	publicStringgetMimeType(){
		returnmimeType;
	}

	publicvoidsetMimeType(StringmimeType){
		this.mimeType=mimeType;
	}

	publiclonggetContentLength(){
		returncontentLength;
	}

	publicvoidsetContentLength(longcontentLength){
		this.contentLength=contentLength;
	}

	publicStringgetExt(){
		returnext;
	}

	publicvoidsetExt(Stringext){
		this.ext=ext;
	}

}

H. java中怎麼用socket 一次傳多個文件啊

客戶端接收多個文件的時候他所獲取到的任然是一個位元組流序列，所以你要確保第版一個文件的權序列有多長，第二個有多長....
然後在客戶端截取這些序列進行保存操作，處理方法有很多種，我以前用過的一種方法是接收數據時前1024個位元組放文件名，然後的8個位元組放文件大小，接著就是文件的信息。客戶端只需要按這種方式解析就行了。。。
希望對你有用。。。。

I. 如何使用java socket來傳輸自定義的數據包

以下分四點進行描述：

1，什麼是Socket
網路上的兩個程序通過一個雙向的通訊連接實現數據的交換，這個雙向鏈路的一端稱為一個Socket。Socket通常用來實現客戶方和服務方的連接。Socket是TCP/IP協議的一個十分流行的編程界面，一個Socket由一個IP地址和一個埠號唯一確定。
但是，Socket所支持的協議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯系的。在Java環境下，Socket編程主要是指基於TCP/IP協議的網路編程。

2，Socket通訊的過程
Server端Listen(監聽)某個埠是否有連接請求，Client端向Server 端發出Connect(連接)請求，Server端向Client端發回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。
對於一個功能齊全的Socket，都要包含以下基本結構，其工作過程包含以下四個基本的步驟：
（1） 創建Socket；
（2） 打開連接到Socket的輸入/出流；
（3） 按照一定的協議對Socket進行讀/寫操作；
（4） 關閉Socket.（在實際應用中，並未使用到顯示的close，雖然很多文章都推薦如此，不過在我的程序中，可能因為程序本身比較簡單，要求不高，所以並未造成什麼影響。）

3，創建Socket
創建Socket
java在包java.net中提供了兩個類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務端。這是兩個封裝得非常好的類，使用很方便。其構造方法如下：
Socket(InetAddress address, int port);
Socket(InetAddress address, int port, boolean stream);
Socket(String host, int prot);
Socket(String host, int prot, boolean stream);
Socket(SocketImpl impl)
Socket(String host, int port, InetAddress localAddr, int localPort)
Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
ServerSocket(int port);
ServerSocket(int port, int backlog);
ServerSocket(int port, int backlog, InetAddress bindAddr)
其中address、host和port分別是雙向連接中另一方的IP地址、主機名和端 口號，stream指明socket是流socket還是數據報socket，localPort表示本地主機的埠號，localAddr和 bindAddr是本地機器的地址（ServerSocket的主機地址），impl是socket的父類，既可以用來創建serverSocket又可 以用來創建Socket。count則表示服務端所能支持的最大連接數。例如：學習視頻網 http://www.xxspw.com
Socket client = new Socket("127.0.01.", 80);
ServerSocket server = new ServerSocket(80);
注意，在選擇埠時，必須小心。每一個埠提供一種特定的服務，只有給出正確的埠，才 能獲得相應的服務。0~1023的埠號為系統所保留，例如http服務的埠號為80,telnet服務的埠號為21,ftp服務的埠號為23, 所以我們在選擇埠號時，最好選擇一個大於1023的數以防止發生沖突。
在創建socket時如果發生錯誤，將產生IOException，在程序中必須對之作出處理。所以在創建Socket或ServerSocket是必須捕獲或拋出例外。

4，簡單的Client/Server程序
1. 客戶端程序
import java.io.*;
import java.net.*;
public class TalkClient {
public static void main(String args[]) {
try{
Socket socket=new Socket("127.0.0.1",4700);
//向本機的4700埠發出客戶請求
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系統標准輸入設備構造BufferedReader對象
PrintWriter os=new PrintWriter(socket.getOutputStream());
//由Socket對象得到輸出流，並構造PrintWriter對象
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket對象得到輸入流，並構造相應的BufferedReader對象
String readline;
readline=sin.readLine(); //從系統標准輸入讀入一字元串
while(!readline.equals("bye")){
//若從標准輸入讀入的字元串為 "bye"則停止循環
os.println(readline);
//將從系統標准輸入讀入的字元串輸出到Server
os.flush();
//刷新輸出流，使Server馬上收到該字元串
System.out.println("Client:"+readline);
//在系統標准輸出上列印讀入的字元串
System.out.println("Server:"+is.readLine());
//從Server讀入一字元串，並列印到標准輸出上
readline=sin.readLine(); //從系統標准輸入讀入一字元串
} //繼續循環
os.close(); //關閉Socket輸出流
is.close(); //關閉Socket輸入流
socket.close(); //關閉Socket
}catch(Exception e) {
System.out.println("Error"+e); //出錯，則列印出錯信息
}
}
}

2. 伺服器端程序
import java.io.*;
import java.net.*;
import java.applet.Applet;
public class TalkServer{
public static void main(String args[]) {
try{
ServerSocket server=null;
try{
server=new ServerSocket(4700);
//創建一個ServerSocket在埠4700監聽客戶請求
}catch(Exception e) {
System.out.println("can not listen to:"+e);
//出錯，列印出錯信息
}
Socket socket=null;
try{
socket=server.accept();
//使用accept()阻塞等待客戶請求，有客戶
//請求到來則產生一個Socket對象，並繼續執行
}catch(Exception e) {
System.out.println("Error."+e);
//出錯，列印出錯信息
}
String line;
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket對象得到輸入流，並構造相應的BufferedReader對象
PrintWriter os=newPrintWriter(socket.getOutputStream());
//由Socket對象得到輸出流，並構造PrintWriter對象
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系統標准輸入設備構造BufferedReader對象
System.out.println("Client:"+is.readLine());
//在標准輸出上列印從客戶端讀入的字元串
line=sin.readLine();
//從標准輸入讀入一字元串
while(!line.equals("bye")){
//如果該字元串為 "bye"，則停止循環
os.println(line);
//向客戶端輸出該字元串
os.flush();
//刷新輸出流，使Client馬上收到該字元串
System.out.println("Server:"+line);
//在系統標准輸出上列印讀入的字元串
System.out.println("Client:"+is.readLine());
//從Client讀入一字元串，並列印到標准輸出上
line=sin.readLine();
//從系統標准輸入讀入一字元串
} //繼續循環
os.close(); //關閉Socket輸出流
is.close(); //關閉Socket輸入流
socket.close(); //關閉Socket
server.close(); //關閉ServerSocket
}catch(Exception e){
System.out.println("Error:"+e);
//出錯，列印出錯信息
}
}
}