socketjava服務端

⑴ java中用socket實現客戶端與服務端雙向連接問題

//服務端程序：
importjava.io.*;
importjava.net.*;

publicclassTCPServer{
	publicstaticvoidmain(String[]args)throwsIOException{
		newTCPServer().init();
	}
	@SuppressWarnings("static-access")
	privatevoidinit()throwsIOException{
		@SuppressWarnings("resource")
		ServerSocketserver=newServerSocket(1000);
		Socketclient=null;
		while(true){
			try{
				client=server.accept();
				BufferedInputStreambis=newBufferedInputStream(client.getInputStream());
				byte[]b=newbyte[1024];
				intlen=0;
				Stringmessage="";
				while((len=bis.read(b))!=-1){
					message=newString(b,0,len);
					System.out.print("客戶端："+client.getInetAddress().getLocalHost().getHostAddress()+"發來消息："+message);
					if("byte".equals(message.trim()))
						client.close();
					PrintWriterpw=newPrintWriter(client.getOutputStream(),true);
					pw.println(message);
				}
			}catch(Exceptione){
				System.err.println("客戶端："+client.getInetAddress().getLocalHost().getHostAddress()+"已斷開連接！");
			}
		}
	}
}

//客戶端程序：
importjava.io.*;
importjava.net.Socket;

{
	publicstaticvoidmain(String[]args)throwsIOException{
		newTCPClient().init();
	}
	privatevoidinit()throwsIOException{
		@SuppressWarnings("resource")
		finalSocketclient=newSocket("127.0.0.1",1000);
		BufferedReaderin=newBufferedReader(newInputStreamReader(System.in));
		Stringsend="";
		while(true){
			send=in.readLine();
			PrintWriterout=newPrintWriter(client.getOutputStream(),true);
			if(!"byte".equals(send.trim()))
				out.println(send);
			else{
				out.println(send);
				System.exit(0);
			}
			newThread(newTCPClient(){
				@SuppressWarnings("static-access")
				publicvoidrun(){
					try{
						BufferedInputStreambis=newBufferedInputStream(client.getInputStream());
						byte[]b=newbyte[1024];
						intlen=0;
						while((len=bis.read(b))!=-1){
							System.out.println("伺服器："+client.getInetAddress().getLocalHost().getHostAddress()+"發來消息："+newString(b,0,len).trim());
						}
					}catch(IOExceptione){
						System.err.println("連接伺服器失敗!");
					}
				}
			}).start();
		}
	}
	publicvoidrun(){}
}

//伺服器測試結果：

客戶端：192.168.0.200發來消息：001 byte

客戶端：192.168.0.200發來消息：byte

客戶端：192.168.0.200 已斷開連接！

客戶端：192.168.0.200發來消息：adasd

客戶端：192.168.0.200 已斷開連接！

//客戶端測試結果：

---001號客戶端--

001byte

伺服器：192.168.0.200發來消息：001byte

byte //001禮貌說跟伺服器說byte

---002號客戶端--

adasd //002客戶端直接關閉程序

伺服器：192.168.0.200發來消息：adasd

⑵ 編寫代碼，使用java ServerSocket創建伺服器端ServerSocket的過程。

packagesocket;

importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.io.PrintWriter;
importjava.net.ServerSocket;
importjava.net.Socket;

publicclassSocketService{
//搭建伺服器端
publicstaticvoidmain(String[]args)throwsIOException{
SocketServicesocketService=newSocketService();
//1、a)創建一個伺服器端Socket，即SocketService
socketService.oneServer();
}
publicvoidoneServer(){
try{
ServerSocketserver=null;
try{
server=newServerSocket(5209);
//b)指定綁定的埠，並監聽此埠。
System.out.println("伺服器啟動成功");
//創建一個ServerSocket在埠5209監聽客戶請求
}catch(Exceptione){
System.out.println("沒有啟動監聽："+e);
//出錯，列印出錯信息
}
Socketsocket=null;
try{
socket=server.accept();
//2、調用accept()方法開始監聽，等待客戶端的連接
//使用accept()阻塞等待客戶請求，有客戶
//請求到來則產生一個Socket對象，並繼續執行
}catch(Exceptione){
System.out.println("Error."+e);
//出錯，列印出錯信息
}
//3、獲取輸入流，並讀取客戶端信息
Stringline;
BufferedReaderin=newBufferedReader(newInputStreamReader(socket.getInputStream()));
//由Socket對象得到輸入流，並構造相應的BufferedReader對象
PrintWriterwriter=newPrintWriter(socket.getOutputStream());
//由Socket對象得到輸出流，並構造PrintWriter對象
BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));
//由系統標准輸入設備構造BufferedReader對象
System.out.println("Client:"+in.readLine());
//在標准輸出上列印從客戶端讀入的字元串
line=br.readLine();
//從標准輸入讀入一字元串
//4、獲取輸出流，響應客戶端的請求
while(!line.equals("end")){
//如果該字元串為"bye"，則停止循環
writer.println(line);
//向客戶端輸出該字元串
writer.flush();
//刷新輸出流，使Client馬上收到該字元串
System.out.println("Server:"+line);
//在系統標准輸出上列印讀入的字元串
System.out.println("Client:"+in.readLine());
//從Client讀入一字元串，並列印到標准輸出上
line=br.readLine();
//從系統標准輸入讀入一字元串
}//繼續循環

//5、關閉資源
writer.close();//關閉Socket輸出流
in.close();//關閉Socket輸入流
socket.close();//關閉Socket
server.close();//關閉ServerSocket
}catch(Exceptione){//出錯，列印出錯信息
System.out.println("Error."+e);
}
}
}

⑶ java socket 客戶端是如何向伺服器端發送消息的

伺服器端和客戶端都是通過SOCKET來進行通信的,首先產生一個 socket實例,通過這個實例,伺服器端調用accept這個方法接收來自客戶端發送的信息.但是在產生socket實例的時候必須初始化一個埠.用來負責接受客戶端的請求！
客戶端要給伺服器發送消息也必須產生一個socket實例，初始化的時候必須指定伺服器的IP地址，並且指定服務接收的埠號,這樣客戶端才能找到伺服器要接收的地方，找到地方就可以發送過去了。和你寫信一樣。找到地址
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

PrintWriter out = new PrintWriter(socket.getOutputStream());

BufferedReader wt = new BufferedReader(new InputStreamReader(System.in));
這個只是用來獲取一個從鍵盤的一個流.傳送給伺服器端的數據都是通過流來表示的。意思是是鍵盤輸入的一個位元組轉化成字元流.並輸出或者寫入！

⑷ java中的socket是什麼意思

所謂socket通常也稱作"套接字"，用於描述IP地址和埠，是一個通信鏈的句柄。應用程序通常通過"套接字"向網路發出請求或者應答網路請求。x0dx0a以J2SDK-1.3為例，Socket和ServerSocket類庫位於java.net包中。ServerSocket用於伺服器端，Socket是建立網路連接時使用的。在連接成功時，應用程序兩端都會產生一個Socket實例，操作這個實例，完成所需的會話。對於一個網路連接來說，套接字是平等的，並沒有差別，不因為在伺服器端或在客戶端而產生不同級別。不管是Socket還是ServerSocket它們的工作都是通過SocketImpl類及其子類完成的。x0dx0a重要的Socket API：x0dx0ajava.net.Socket繼承於java.lang.Object，有八個構造器，其方法並不鬧李多，下面介紹使用最頻繁的三個方法，其它方法大家可以見JDK-1.3文檔。x0dx0a. Accept方法用於產生"阻塞"，直到接受到一個連接，並且返回一個客戶端的Socket對象實例。"阻塞"是一個術語，它使程序運行暫時"停留"在這個地方，直到一個會話產生，然後程序繼續；通常"阻塞"是由循環產生的。x0dx0a. getInputStream方法獲得網路連接輸入，同時返回一個InputStream對象實例。x0dx0a. getOutputStream方法連接的另一端將得到輸入，同時返回一個OutputStream對象實例。x0dx0a注意：其中getInputStream和getOutputStream方法均會產生一個IOException，它必須被捕獲，因為它們返回的流對象，通常都會被另一個流對象使用。x0dx0a2ServerSocket類例子編輯x0dx0ax0dx0apackage com.lanber.socket;x0dx0aimport java.io.DataInputStream;x0dx0aimport java.io.DataOutputStream;x0dx0aimport java.io.IOException;x0dx0aimport java.net.ServerSocket;x0dx0aimport java.net.Socket;x0dx0apublic class ServerDemo {x0dx0a/**x0dx0a* 注意：Socket的發送與接收是需要同步進行的，即客戶端發送一條信息，伺服器必需先接收這條信息，x0dx0a* 而後才可以碰吵向客戶端發送信息，否則將會有運行時出錯。x0dx0a* @param argsx0dx0a*/笑彎侍x0dx0apublic static void main(String[] args) {x0dx0aServerSocket ss = null;x0dx0atry {x0dx0ass = new ServerSocket(8888);x0dx0a//伺服器接收到客戶端的數據後，創建與此客戶端對話的Socketx0dx0aSocket socket = ss.accept();x0dx0a//用於向客戶端發送數據的輸出流x0dx0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream());x0dx0a//用於接收客戶端發來的數據的輸入流x0dx0aDataInputStream dis = new DataInputStream(socket.getInputStream());x0dx0aSystem.out.println("伺服器接收到客戶端的連接請求：" + dis.readUTF());x0dx0a//伺服器向客戶端發送連接成功確認信息x0dx0ados.writeUTF("接受連接請求，連接成功!");x0dx0a//不需要繼續使用此連接時，關閉連接x0dx0asocket.close();x0dx0ass.close();x0dx0a} catch (IOException e) {x0dx0ae.printStackTrace();x0dx0a}x0dx0a}x0dx0a}x0dx0ax0dx0a3客戶端的例子編輯x0dx0apackage com.lanber.socket;x0dx0aimportjava.io.DataInputStream;x0dx0aimport java.io.DataOutputStream;x0dx0aimportjava.io.IOException;x0dx0aimport java.io.OutputStream;x0dx0aimport java.net.Socket;x0dx0aimport java.net.UnknownHostException;x0dx0apublic class ClientDemo {x0dx0a/**x0dx0a* @param argsx0dx0a*/x0dx0apublic static void main(String[] args) {x0dx0aSocket socket = null;x0dx0atry {x0dx0asocket = new Socket("localhost",8888);x0dx0a//獲取輸出流，用於客戶端向伺服器端發送數據x0dx0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream());x0dx0a//獲取輸入流，用於接收伺服器端發送來的數據x0dx0aDataInputStream dis = new DataInputStream(socket.getInputStream());x0dx0a//客戶端向伺服器端發送數據x0dx0ados.writeUTF("我是客戶端，請求連接!");x0dx0a//列印出從伺服器端接收到的數據x0dx0aSystem.out.println(dis.readUTF());x0dx0a//不需要繼續使用此連接時，記得關閉哦x0dx0asocket.close();x0dx0a} catch (UnknownHostException e) {x0dx0ae.printStackTrace();x0dx0a} catch (IOException e) {x0dx0ae.printStackTrace();x0dx0a}x0dx0a}x0dx0a}