277
網(wǎng)絡(luò)上的兩個程序通過一個雙向的通信連接實現(xiàn)數(shù)據(jù)的交換，這個連接的一端稱為一個socket。
建立網(wǎng)絡(luò)通信連接至少要一對端口號(socket)。socket 本質(zhì)是編程接口(API)，對TCP/IP的封裝，TCP/IP也要提供可供程序員做網(wǎng)絡(luò)開發(fā)所用的接口，這就是Socket編程接口;HTTP是轎車，提供了封裝或者顯示數(shù)據(jù)的具體形式;Socket是發(fā)動機，提供了網(wǎng)絡(luò)通信的能力。
下載eclipse：https://www.eclipse.org/
本文將給出完整 Socket 通信代碼，在 eclipse 中親測有效。在Android Studio中用Java開發(fā)也是一樣的，只是把代碼和控件搭配一下，注冊監(jiān)聽就好。區(qū)別就是在 AS 中 import 的聲明不太一樣，然后窗口不需要自己建立。
效果如圖
在eclipse中，F(xiàn)ile→New→Java Project→起個英文名字→Finish（我起的名字是TCP）
目錄結(jié)構(gòu)：
新建完以后有個src默認包，右鍵 src→New→Package→ 輸入 com.net（因為程序里我用的包的名字是這個，你可以同時兩個一起改）→ Finish
然后右鍵 com.net → New → Class → 輸入 TCPClient（因為我程序里面用的這個類名稱）
然后右鍵 com.net → New → Class → 輸入 TCPServer（因為我程序里面用的這個類名稱）
兩個里面分別粘貼代碼：
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("從客戶端接受的數(shù)據(jù):"+"n");
ServerSocket ss=null;
try{
ss=new ServerSocket(8866); //端口號
}catch(BindException e){
System.exit(0);
}catch(IOException e){
e.printStackTrace();
}
Frame f=new Frame("服務器端"); //窗體名稱
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("向服務器端發(fā)送的數(shù)據(jù):");
client.setTitle("客戶端");
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();
}
}
}
}
然后先運行服務器，再運行客戶端，否則會報錯，因為Socket通信本質(zhì)是先打開服務器監(jiān)聽端口。然后就會出現(xiàn)效果圖。
本機回環(huán) IP 是 127.0.0.1，你可以改為其他 IP 地址，即可實現(xiàn)跨機 Socket 通信。
·················· END ··················
