網(wǎng)絡(luò)上的兩個(gè)程序通過(guò)一個(gè)雙向的通信連接實(shí)現(xiàn)數(shù)據(jù)的交換,這個(gè)連接的一端稱(chēng)為一個(gè)socket。
建立網(wǎng)絡(luò)通信連接至少要一對(duì)端口號(hào)(socket)。socket 本質(zhì)是編程接口(API),對(duì)TCP/IP的封裝,TCP/IP也要提供可供程序員做網(wǎng)絡(luò)開(kāi)發(fā)所用的接口,這就是Socket編程接口;HTTP是轎車(chē),提供了封裝或者顯示數(shù)據(jù)的具體形式;Socket是發(fā)動(dòng)機(jī),提供了網(wǎng)絡(luò)通信的能力。
下載eclipse:https://www.eclipse.org/
本文將給出完整 Socket 通信代碼,在 eclipse 中親測(cè)有效。在Android Studio中用Java開(kāi)發(fā)也是一樣的,只是把代碼和控件搭配一下,注冊(cè)監(jiān)聽(tīng)就好。區(qū)別就是在 AS 中 import 的聲明不太一樣,然后窗口不需要自己建立。
效果如圖
在eclipse中,F(xiàn)ile→New→Java Project→起個(gè)英文名字→Finish(我起的名字是TCP)
目錄結(jié)構(gòu):
新建完以后有個(gè)src默認(rèn)包,右鍵 src→New→Package→ 輸入 com.net(因?yàn)槌绦蚶镂矣玫陌拿质沁@個(gè),你可以同時(shí)兩個(gè)一起改)→ Finish
然后右鍵 com.net → New → Class → 輸入 TCPClient(因?yàn)槲页绦蚶锩嬗玫倪@個(gè)類(lèi)名稱(chēng))
然后右鍵 com.net → New → Class → 輸入 TCPServer(因?yàn)槲页绦蚶锩嬗玫倪@個(gè)類(lèi)名稱(chēng))
兩個(gè)里面分別粘貼代碼:
TCPServer
package com.net;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
public class TCPServer {
static DataInputStream dis=null;
public static void main(String[] args){
boolean started=false;
Socket s=null;
TextArea ta=new TextArea();
ta.append("從客戶(hù)端接受的數(shù)據(jù):"+"n");
ServerSocket ss=null;
try{
ss=new ServerSocket(8866); //端口號(hào)
}catch(BindException e){
System.exit(0);
}catch(IOException e){
e.printStackTrace();
}
Frame f=new Frame("服務(wù)器端"); //窗體名稱(chēng)
f.setLocation(300, 300); //窗體出現(xiàn)位置
f.setSize(200, 200); //窗體大小
f.add(ta,BorderLayout.NORTH);
f.pack();
f.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0);
}
});
f.setVisible(true);
try{ //try-catch塊捕捉異常
started=true;
while(started){
boolean bConnected=false;
s=ss.accept();
bConnected=true;
dis=new DataInputStream(s.getInputStream());
while(bConnected){
String str=dis.readUTF();
ta.append(str+"n");
}
}
}catch(EOFException e){
System.out.println("Client closed!");
}catch(IOException e){
e.printStackTrace();
}finally{
try{
if(dis!=null)
dis.close();
if(s!=null)
s.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}
TCPClient
package com.net;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class TCPClient extends Frame{
Socket s=null;
DataOutputStream dos=null;
DataInputStream dis=null;
TextField tf=new TextField(40);
List list=new List(6);
public static void main(String[] args){
TCPClient client=new TCPClient();
client.list.add("向服務(wù)器端發(fā)送的數(shù)據(jù):");
client.setTitle("客戶(hù)端");
client.run();
}
public void run(){
setLocation(400,300);
this.setSize(300, 300);
add(tf,BorderLayout.SOUTH);
add(list,BorderLayout.NORTH);
pack();
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
disconnect();
System.exit(0);
}
});
tf.addActionListener(new MyListener());
setVisible(true);
connect();
}
public void connect(){
try{
s=new Socket("127.0.0.1",8866);
dos=new DataOutputStream(s.getOutputStream());
}catch(UnknownHostException e){
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();
}
}
public void disconnect(){
try{
dos.close();
s.close();
}catch(IOException e){
e.printStackTrace();
}
}
private class MyListener implements ActionListener{
public void actionPerformed(ActionEvent e){
String s1=null;
String s2=null;
String str=tf.getText().trim();
list.add(str);
tf.setText("");
try{
dos.writeUTF(str);
dos.flush();
}catch(IOException e1){
e1.printStackTrace();
}
}
}
}
然后先運(yùn)行服務(wù)器,再運(yùn)行客戶(hù)端,否則會(huì)報(bào)錯(cuò),因?yàn)镾ocket通信本質(zhì)是先打開(kāi)服務(wù)器監(jiān)聽(tīng)端口。然后就會(huì)出現(xiàn)效果圖。
本機(jī)回環(huán) IP 是 127.0.0.1,你可以改為其他 IP 地址,即可實(shí)現(xiàn)跨機(jī) Socket 通信。
·················· END ··················