Socks實際上是什麼：實際上是提供了精彩通信的埠，在通信之前雙方都必須要創造一個端點才能通信，其實感覺socket跟電腦的三次握手有些相似，分為三個步驟： （1）伺服器監聽 （2）客戶端請求 （3）連接確認 ...
0x00前言和思維導圖
Socks實際上是什麼：實際上是提供了精彩通信的埠，在通信之前雙方都必須要創造一個端點才能通信，其實感覺socket跟電腦的三次握手有些相似，分為三個步驟：
（1）伺服器監聽：伺服器不知道下一個客戶端的具體套接字，而是處於等待連接的狀態
（2）客戶端請求：由客戶端的套接字提出請求，連接目標是伺服器的套接字。
（3）連接確認：伺服器接收到客戶端的套接字請求，它就響應客戶端的請求，創建一個新的線程把伺服器套接字的具體描述發個客戶端，客戶端確認以後，這個連接就建立好了，服務端繼續進入監聽狀態。
0x01socks的編程
0x1客戶端的編寫
(1)首先是Socket類的構造方法public Socket(String host, int port)，前面是你連接的服務端的ip，後面是連接埠。
(2)socketlei下麵的成員方法
getInputStream()
返回此套接字的輸入流
getOutputStream()
返回此套接字的輸出流
void bind(SocketAddress bindpoint)
將套接字綁定到本地地址。
void close()
關閉此套接字。
void connect(SocketAddress endpoint)
將此套接字連接到伺服器。
(3)一些方法的使用，傳輸數據
a.outputstream.write("數據".getbytes())需要把類型轉化成位元組類型看一看它的源碼public void write(byte b[])
b.可以利用另一個類去完成PrintWriter : 高級輸出流
c.PrintWriter pw3 = new PrintWriter(socket.getOutputStream());發送給伺服器或者客戶端
d.Scanner scan3 = new Scanner(socket.getInputStream())網路通信裡面去讀取對方發給我的信息
e.用緩衝流去接受信息
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
class Mysocks_test1{
public static void main(String[] args) {
try {
Socket socket=new Socket("127.0.0.1",9099);
OutputStream os=socket.getOutputStream();
PrintWriter pw=new PrintWriter(os);
pw.write("客戶端發送信息");
pw.flush();
socket.shutdownOutput();
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));//按照字元流讀取，緩衝流
String info=null;
while ((info= br.readLine())!=null){
System.out.println("我接受到的信息是"+info);
}
br.close();
is.close();
os.close();
pw.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
0x2服務端的編寫
(1)構建一個線程去接受一個客戶端的請求與客戶端交互
(2)InetAddress類從名字就可以看出來ip地址類，
用法：socket.getInetAddress()，獲取ip地址
構造方法public InetAddress getInetAddress()返回的是一個InetAddress對象
看一下代碼
點擊查看代碼
public class JAVA_serverSocket {
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8080);
Socket socket=new Socket();
while (true){
socket=serverSocket.accept();
ServerThread thread=new ServerThread(socket);
thread.start();
InetAddress address=socket.getInetAddress();//獲取客戶端的IP
System.out.println("目標客戶端的ip是"+address);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
點擊查看代碼
public class ServerThread extends Thread{
private Socket socket=null;
public ServerThread(Socket socket){
this.socket=socket;
}
@Override
public void run() {
InputStream is=null;
InputStreamReader isr=null;
BufferedReader br=null;
OutputStream os=null;
PrintWriter pw=null;
try {
is=socket.getInputStream();
isr=new InputStreamReader(is);
br=new BufferedReader(isr);
String info=null;
while ((info= br.readLine())!=null);{
System.out.println("我是服務,客戶機說"+br.readLine());
}
socket.shutdownInput();
os=socket.getOutputStream();
pw=new PrintWriter(os);
pw.write("伺服器歡迎你");
} catch (IOException e) {
e.printStackTrace();
}finally {
try{
if (pw != null) {
pw.close();
if (os != null) {
os.close();
} }
if (br != null) {
br.close();
}
if (isr != null) {
isr.close();
}
if (is != null) {
is.close();
}
if (socket != null) {
socket.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
