上篇教程回顧
ServerSocket --監聽客戶端的連接,他的作用主要是建立一個連接
-ServerSocket -建立連接,拿到一個Socket
-Telnet 127.0.0.1 8888- 客戶端使用Telnet訪問服務端 建立連接
-服務端可以拿到一個Socket的物件
-獲取這個物件的輸入輸出流
-寫入和讀取資料
Socket連接模型

服務端和客戶端通過Socket進行連接,雖然是一個Socket,但是相當于把這一個Socket分成了兩個管道,服務端拿著這兩根管道的一段,客戶端拿著這兩根管道的另一端,
- Server的input與Client的output相連
- 客戶端發送資料,從Client的output發送,傳輸到Server的input接收
- 服務端發送資料,從Server的output發送,傳輸到Client的input接收
- 如果實作雙端收發通信,每個程式至少需要兩個執行緒
訊息協議
TCP:面向連接
UDP:不需要建立連接 類似資料報
TCP:穩定,要求發送資料前必須確認雙方都可以收發訊息
連接程序 : 三次握手
Server--------------------- Client
1: 監聽-----------------------發送請求
這步之后,服務端知道客戶端可以發資料
2:收到請求,應答------------收到應答訊息,發送應答包給s
這步之后,客戶端知道服務端可收發資料
3:收到應答
這步之后,服務端知道客戶端可以收資料
傳輸程序中資料型別需要了解的細節
- char:16bit 兩個位元組Byte
- 資料發送的單位:資料每次發送一個byte,一個char需要發送兩次單位元組
- 發送文字訊息
- 第一部分應發送字串的長度,以便確定位元組陣列的長度
- 對方,讀取的第一個位元組是訊息長度,定義一個固定容量大小的容器
- 第二部分為訊息內容
- 對方,讀取對應長度的位元組后,將其轉成對應的資料(String物件)
資料型別:
- 整數型:byte short int long
- 浮點型:float double
- 字符型:char
- 布爾型:boolean
- char=16bit=2 byte unicode編碼
- utf-8:1-6個位元組組成一個漢字
1100 1101 1010
如這個資料第一個位元組有兩個1,則代表它是一個漢子,并且后面兩個位元組都表示這個漢字,如果有111就讀取后面三個位元組
因為英文用ASCII碼存盤0-127,第一位不可能是1,通過第一個位元組可以判斷是中文還是英文 - 英文字母全部兼容:ASCII 0-127 二進制碼:0-255,所以0-127一定以0開頭,漢字是16bit 0-65536
TCP通信代碼
通過自己撰寫一個客戶端和服務端,實作訊息的首發,這里的核心主要是自己撰寫通信協議,我在這里第一次發送到是資料的長度,并且做了資料加密,客戶端需要決議這個資料長度,并創建對應長度的陣列,才能正確讀取訊息內容
MsgClient
package com.lding.net;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
/**
* @program: Net
* @description: Tcp客戶端測驗
* @author: 王丁
* @date: 2021-09-20 10:04
**/
public class TcpClient {
public static void main(String[] args) throws IOException {
Socket socket=new Socket("127.0.0.1",8888);
OutputStream output=socket.getOutputStream();
InputStream input=socket.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(input);
// byte[] msgbyte=new byte[30];
// input.read(msgbyte);
// System.out.println("服務器說:"+new String(msgbyte));
int length1=input.read();
int length2=input.read();
int msglength=length2*3+length1;
System.out.println("訊息長度為:"+msglength);
byte[] msgbytes=new byte[msglength];
input.read(msgbytes);
String getmsg=new String(msgbytes);
System.out.println("服務器說:"+getmsg);
}
}
MsgServer
package com.lding.net;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @program: Net
* @description: Tcp服務端測驗
* @author: 王丁
* @date: 2021-09-20 10:03
**/
public class TcpServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(8888);
//監聽客戶端的Socket連接
System.out.println("服務端開啟:ip:"+serverSocket.getInetAddress().getHostAddress()+"埠號:"+serverSocket.getLocalSocketAddress());
System.out.println("正在等待有緣人......");
Socket socketClient = serverSocket.accept();
System.out.println("客戶端已連接:"+socketClient.getInetAddress());
System.out.println("客戶端埠"+socketClient.getPort());
OutputStream output=socketClient.getOutputStream();
InputStream input=socketClient.getInputStream();
// output.write("服務器連接成功!!!".getBytes());
// output.flush();//重繪緩沖,管道強制刷出
String msg="服務器連接成功!!!中秋快樂!<include/bits/stdc++.h> using namespace std";
byte[] msgBytes=msg.getBytes();
int length1=msgBytes.length%3;
int length2=msgBytes.length/3;
output.write(length1);
output.write(length2);
output.write(msgBytes);
output.flush();
// while(input.read()!=-1){
// System.out.println((char) input.read());
// }
}
}
運行結果


還可以完善的地方
1、之后通信協議可以加入,通過客戶端串列,轉發訊息內容到多個客戶端
2、攜帶用戶名、目標用戶名等等
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/301805.html
標籤:其他
上一篇:【Java】多型與抽象類
下一篇:資料在記憶體中的存盤(一)
