客戶:
導入Java . net . socket;
導入Java . io . inputstream;
導入Java . io . output stream;
導入Java . io . inputstreamreader;
導入Java . io . buffered reader;
公共類TcpClient {
公共靜態void main(String[] args)引發異常
{
//創建客戶端Socket服務,使主機和duank。
插座s =新插座(" 192.168.1.104 ",10002);//連接固定的主機和端口。
//要發送數據,請獲取套接字中的iostream。
output stream out = s . get output stream();
InputStreamReader ISR = new InputStreamReader(system . in);
BufferedReader br =新buffered reader(ISR);
String line = null
//讀取服務器發送的數據。
InputStream in = s . getinputstream();
byte[] buf =新字節[1024];
while((line = br.readLine())!=空)
{
out . write(line . getbytes());
如果(“886”。等於(行))
打破;
int len = in . read(buf);
字符串內容=新字符串(buf,0,len);
System.out.println("服務器:"+內容);
}
s . close();
}
}
服務器:
/*
*需求分析:
*使用TCP協議,編寫服務器。以便服務器可以從客戶端接收信息並向客戶端發送信息。
* */
打包JavaNetProgramming
導入Java . net . server socket;
導入Java . net . socket;
導入Java . io . inputstream;
導入Java . io . output stream;
導入Java . io . inputstreamreader;
導入Java . io . buffered reader;
公共類TcpServer {
公共靜態void main(String[] args)引發異常
{
//建立服務器的Socket服務,監聽壹個端口。
server socket ss = new server socket(10002);
socket s = ss . accept();
InputStream is = s . getinputstream();
//從服務器向客戶端發送數據
output stream out = s . get output stream();
InputStreamReader ISR = new InputStreamReader(system . in);
BufferedReader br =新buffered reader(ISR);
String line = null
while(真)
{
//通過accept()方法從客戶端獲取Socket對象。
//system . out . println(" getByNanme():"+s . getine address());
system . out . print(" getHostAddress():"+s . getine address())。getHostAddress());
//獲取客戶端發送的數據,需要使用客戶端對象的read流讀取數據。
byte[] buf =新字節[1024];
int len = is . read(buf);//將流中的數據讀入字節數組。
字符串內容=新字符串(buf,0,len);
system . out . println("+content);
如果(“886”。等於(內容))
打破;
while((line = br.readLine())!=空)
{
out . write(line . getbytes());
打破;
}
}
s . close();//如果循環中有判斷語句,這句話就不會出錯。
ss . close();
}
}