2. 程式人生 > >java基礎----網路程式設計 tcp

java基礎----網路程式設計 tcp

阿新 • • 發佈：2018-11-03

package cn.itcast.tcp;


import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;


/*
 
 UDP通訊協議的特點：
1. 將資料極封裝為資料包，面向無連線。
2. 每個資料包大小限制在64K中
3.因為無連線，所以不可靠
4. 因為不需要建立連線，所以速度快
5.udp 通訊是不分服務端與客戶端的，只分傳送端與接收端。


TCP通訊協議特點：
1. tcp是基於IO流進行資料 的傳輸 的，面向連線。
  2. tcp進行資料傳輸的時候是沒有大小限制的。
  3. tcp是面向連線，通過三次握手的機制保證資料的完整性。 可靠協議。
  4. tcp是面向連線的，所以速度慢。
  5. tcp是區分客戶端與服務端 的。
 
  比如： 打電話、 QQ\feiQ的檔案傳輸、 迅雷下載.... 
 
tcp協議下的Socket：
Socket(客戶端) , tcp的客戶端一旦啟動馬上要與服務端進行連線。
ServerSocket(服務端類)


tcp的客戶端使用步驟：
1. 建立tcp的客戶端服務。
2. 獲取到對應的流物件。
3.寫出或讀取資料
4. 關閉資源。




 */


//tcp客戶端
public class Demo1Client {

public static void main(String[] args) throws IOException{
//建立tcp的服務
Socket socket  = new Socket(InetAddress.getLocalHost(),9090);
//獲取到Socket的輸出流物件
OutputStream outputStream = socket.getOutputStream();
//利用輸出流物件把資料寫出即可。
outputStream.write("服務端你好".getBytes());

//獲取到輸入流物件，讀取服務端回送的資料。
InputStream inputStream = socket.getInputStream();
byte[] buf = new byte[1024];
int length = inputStream.read(buf);
System.out.println("客戶端接收到的資料："+ new String(buf,0,length));

//關閉資源
socket.close();
}
}


package cn.itcast.tcp;



import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;


//tcp的服務端
/*
java.net.BindException:   埠被佔用。


ServerSocket的使用 步驟
1. 建立tcp服務端 的服務。
2. 接受客戶端的連線產生一個Socket.
3. 獲取對應的流物件讀取或者寫出資料。
4. 關閉資源。




為什麼ServerSocket不設計一個getInputStream與getOutputStream 呢？ 


*/
//服務端
public class Demo1Server {


public static void main(String[] args) throws Exception {
//建立Tcp的服務端,並且監聽一個埠。
ServerSocket serverSocket = new ServerSocket(9090);
//接受客戶端的連線
Socket socket  =  serverSocket.accept(); //accept()  接受客戶端的連線 該方法也是一個阻塞型的方法，沒有客戶端與其連線時，會一直等待下去。
//獲取輸入流物件，讀取客戶端傳送的內容。
InputStream inputStream = socket.getInputStream();
byte[] buf = new byte[1024];
int length = 0;
length = inputStream.read(buf);
System.out.println("服務端接收："+ new String(buf,0,length));

//獲取socket輸出流物件，向客戶端傳送資料
OutputStream outputStream = socket.getOutputStream();
outputStream.write("客戶端你好啊！".getBytes());


//關閉資源
serverSocket.close();

}

}



package cn.itcast.tcp;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;


/*
 需求： 客戶端與服務端一問一答聊天。
 
 
 1.如果使用BuffrerdReader的readline方法一定要加上\r\n才把資料寫出。
 2.使用字元流一定要呼叫flush方法資料才會寫出。
 
 */




//聊天的客戶端
public class ChatClient {


public static void main(String[] args) throws IOException {
//建立tcp的客戶端服務
Socket socket = new Socket(InetAddress.getLocalHost(),9090);
//獲取socket的輸出流物件。
OutputStreamWriter socketOut =new OutputStreamWriter(socket.getOutputStream());
//獲取socket的輸入流物件
BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//獲取鍵盤的輸入流物件，讀取資料
BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));

String line = null;
//不斷的讀取鍵盤錄入的資料，然後把資料寫出
while((line = keyReader.readLine())!=null){
socketOut.write(line+"\r\n");
//重新整理
socketOut.flush();

//讀取服務端回送的資料
line = socketReader.readLine();
System.out.println("服務端回送的資料是："+line);
}
//關閉資源
socket.close();
}


}





package cn.itcast.tcp;


import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;


//tcp的服務端
/*
java.net.BindException:   埠被佔用。


ServerSocket的使用 步驟
1. 建立tcp服務端 的服務。
2. 接受客戶端的連線產生一個Socket.
3. 獲取對應的流物件讀取或者寫出資料。
4. 關閉資源。




為什麼ServerSocket不設計一個getInputStream與getOutputStream 呢？ 


*/
//服務端
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;


/*
 聊天的服務端
 
 
 瀏覽器與伺服器之間的資料傳輸就是使用了Tcp協議通訊的的
 */
public class ChatServer {


public static void main(String[] args) throws IOException {
//建立tcp的服務端
ServerSocket serverSocket = new ServerSocket(9090);
//接受客戶端的連線，產生一個Socket
Socket socket = serverSocket.accept();
//獲取到Socket的輸入流物件
BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//獲取到Socket輸出流物件
OutputStreamWriter socketOut =  new OutputStreamWriter(socket.getOutputStream());

//獲取鍵盤的輸入流物件
BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));


//讀取客戶端的資料
String line = null;
while((line = socketReader.readLine())!=null){
System.out.println("服務端接收到的資料："+ line);

System.out.println("請輸入回送給客戶端的資料：");
line = keyReader.readLine();
socketOut.write(line+"\r\n");
socketOut.flush();
}

//關閉資源
serverSocket.close();
}

}




package cn.itcast.tcp;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;


//模擬Tomcat伺服器
public class TomcatDemo extends Thread {

Socket socket;

public TomcatDemo(Socket socket){
this.socket = socket;
}


public void run() {
try {
//獲取socket的輸出流物件
OutputStream outputStream = socket.getOutputStream();
//把資料寫到瀏覽器上
outputStream.write("<html><head><title>aaa</title></head><body>你好啊瀏覽器</body></html>".getBytes());
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}



public static void main(String[] args) throws IOException {
//建立tcp的服務端
ServerSocket serverSocket = new ServerSocket(9090);
//不斷的接受客戶端的連線
while(true){
Socket socket = serverSocket.accept();
new TomcatDemo(socket).start();
}
}

}





多執行緒下載圖片



package cn.itcast.tcp;


import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashSet;


/*
1. 編寫一個服務端可以給多個客戶端傳送圖片。 （多執行緒）


*/
public class ImageServer extends Thread {

Socket socket ;

//使用該集合是用於儲存ip地址的。
static HashSet<String> ips = new HashSet<String>();

public  ImageServer(Socket socket) {
this.socket = socket;
}

@Override
public void run() {
try {
//獲取到socket輸出流物件
OutputStream outputStream = socket.getOutputStream();
//獲取圖片的輸入流物件
FileInputStream fileInputStream = new FileInputStream("F:\\美女\\3.jpg");
//讀取圖片資料，把資料寫出
byte[] buf = new byte[1024];
int length = 0 ; 
while((length = fileInputStream.read(buf))!=-1){

outputStream.write(buf,0,length);
}
String ip = socket.getInetAddress().getHostAddress();   // socket.getInetAddress() 獲取對方的IP地址
if(ips.add(ip)){
System.out.println("恭喜"+ip+"同學成功下載，當前下載的人數是："+ ips.size());
}



//關閉資源
fileInputStream.close();
socket.close();
}catch (IOException e) {

}
}


public static void main(String[] args) throws IOException {
//建立tcp的服務 ,並且要監聽一個埠
ServerSocket serverSocket  = new ServerSocket(9090);
while(true){
//接受使用者的連結。
Socket socket = serverSocket.accept();
new ImageServer(socket).start();

}
}


}


package cn.itcast.tcp;


import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;


//下載圖片的客戶端
public class ImageClient {


public static void main(String[] args) throws Exception{
//建立tcp的服務
Socket socket = new Socket(InetAddress.getLocalHost(),9090);
//獲取socket的輸入流物件
InputStream inputStream = socket.getInputStream();
//獲取檔案的輸出流物件
FileOutputStream fileOutputStream = new FileOutputStream("F:\\3.jpg");
//邊讀邊寫
byte[] buf = new byte[1024];
int length = 0 ; 
while((length = inputStream.read(buf))!=-1){
fileOutputStream.write(buf,0,length);
}
//關閉資源
fileOutputStream.close();
socket.close();

}

}




多使用者登入


package cn.itcast.tcp;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;




/*
2.  實現登陸與註冊 功能。  
客戶端與服務端連線的時候，就要提示客戶端請選擇功能。

客戶端註冊的時候，使用者名稱與密碼都是傳送給服務端 的，服務端需要把資料儲存到服務端的檔案上。

登陸： 登陸的時候客戶端輸入使用者名稱與密碼傳送給服務端，服務端需要校驗，返回結果給客戶端。
*/


public class LoginClient {

public static void main(String[] args) throws IOException {
Socket socket = new Socket(InetAddress.getLocalHost(),9090);
//獲取socket的輸出流物件
OutputStreamWriter  socketOut = new OutputStreamWriter(socket.getOutputStream());

//獲取到socket的輸入流物件
BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//獲取到鍵盤的輸入流物件
BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));
while(true){
System.out.println("請選擇功能： A(登陸)  B(註冊)");
String option = keyReader.readLine();
if("a".equalsIgnoreCase(option)){
getInfo(socketOut, keyReader, option);
//讀取伺服器反饋的資訊
String line = socketReader.readLine();
System.out.println(line);
}else if("b".equalsIgnoreCase(option)){
getInfo(socketOut, keyReader, option);
//讀取伺服器反饋的資訊
String line = socketReader.readLine();
System.out.println(line);
}


}


}


public static void getInfo(OutputStreamWriter  socketOut,BufferedReader keyReader, String option)
throws IOException {
System.out.println("請輸入使用者名稱:");
String userName = keyReader.readLine();
System.out.println("請輸入密碼：");
String password = keyReader.readLine();
String info = option +" "+userName+" "+password+"\r\n";
socketOut.write(info);
socketOut.flush();
}

}




package cn.itcast.tcp;


import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Properties;


public class LoginServer extends Thread {


Socket socket;


static File file = new File("F:\\users.properties");


public LoginServer(Socket socket) {
this.socket = socket;
}


static {
try {
if (!file.exists()) {
file.createNewFile();
}
} catch (IOException e) {
e.printStackTrace();
}


}


@Override
public void run() {
while(true){

try {
// 獲取socket的輸入流物件
BufferedReader bufferedReader = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
// 獲取socket的輸出流物件
OutputStreamWriter socketOut = new OutputStreamWriter(
socket.getOutputStream());

// 讀取客戶端輸入的資訊
String info = bufferedReader.readLine();
String[] datas = info.split(" ");
// 獲取到使用者 的選擇功能
String option = datas[0];
// 註冊
String userName = datas[1];

String password = datas[2];

if ("a".equalsIgnoreCase(option)) {
// 登陸
Properties properties = new Properties();
// 載入配置檔案
properties.load(new FileReader(file));
if (properties.containsKey(userName)) {
String tempPass = properties.getProperty(userName);
if (password.equals(tempPass)) {
socketOut.write("歡迎" + userName + "登陸成功\r\n");

} else {
socketOut.write("密碼錯誤\r\n");
}

} else {
socketOut.write("使用者名稱不存在，請重新輸入...\r\n");
}

socketOut.flush();

} else if ("b".equalsIgnoreCase(option)) {

// 建立一個配置檔案類
Properties properties = new Properties();
//載入原來的配置檔案
properties.load(new FileReader(file));
if (!properties.containsKey(userName)) {
// 不存在該使用者名稱
properties.setProperty(userName, password);
// 生成一個配置檔案
properties.store(new FileWriter(file), "users");
socketOut.write("註冊成功..\r\n");
} else {
// 存在使用者名稱
socketOut.write("使用者名稱已經被註冊，請重新輸入\r\n");
}
socketOut.flush();
}
} catch (Exception e) {
e.printStackTrace();
}
}


}


public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(9090);
while (true) {
Socket socket = serverSocket.accept();
new LoginServer(socket).start();
}


}


}

相關推薦

java基礎----網路程式設計 tcp

package cn.itcast.tcp; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.n

Java基礎---網路程式設計 ip udp

package cn.itcast.ip; import java.io.IOException; import java.net.InetAddress; import java.net.UnknownHostException; /*  網路程式設計

『黑馬程式設計師』---java--網路程式設計--TCP基礎

----------- android培訓、java培訓、java學習型技術部落格、期待與您交流！ ------------ TCP傳輸 ✔Socket和ServerSocket ✔建立客戶端和服務端 ✔建立連線後,通過Socket中的IO流進行資料的傳輸 ✔關閉Socke

C#.網路程式設計 Tcp基礎（二） TCP組包、粘包、拆包的原理

一、TCP粘包，拆包及解決方法    轉https://blog.csdn.net/scythe666/article/details/51996268 以下是轉發的部分內容          我們都知道TCP屬於傳

java 網路程式設計——TCP 的三次握手和四次揮手

文章目錄 TCP報頭 三次握手 未連線佇列 四次揮手 狀態詳解 在TCP/IP協議中,TCP協議提供可靠的連線服務,採用三次握手建立一個連線. TCP報頭 埠號：用來標識

Java：網路程式設計基礎

網路通訊的三個條件 IP地址 網路中裝置的標識，不易記憶，可用主機名 埠 用於標識程序的邏輯地址，不同程序的標識 協議 通訊的規則，如TCP，UDP IP地址 IP地址的組成：網路號+主機號共4×8 32位 A類IP地址:第一段號碼為

java：網路程式設計（InetAddress，InetSocketAddress，URL，TCP（Socket與SeverSocket），TCP與UDP的區別）

  InerAddress: /**IP地址:在網路上唯一標示一臺計算機 * 埠號:標示計算機上不同的應用程式 * java.net.InetAddress類:此類表示網際網路協議 (IP) 地址。 * 常用方法: * getByName(String host) 在給定主機名的情況下

java se基礎--網路程式設計

十一.網路程式設計1.要想實現網路傳輸,需要考慮的問題有哪些?         1.1如何才能準確的定位網路上的一臺主機?         1.2如何才能進行可靠的、高效的資料傳輸?2.java如何實現的網路通訊         2.1使用IP地址---定位一臺主機   使用

java-網路程式設計(TCP-服務端響應客戶端)

　網路程式設計詳解-TCP 　　一，TCP協議的特點           　　  面向連線的協議(有傳送端就一定要有接收端)       

Java網路程式設計TCP協議傳送接收資料

一、客戶端傳送，伺服器端接收 package net; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; /* * TC

java網路程式設計TCP傳輸—流操作—拿到源後的寫入動作

在網路程式設計中的TCP傳輸裡，拿到Socket的源後，應該怎麼進行讀寫操作呢，下面我列舉了兩種方法，希望大家幫忙補充···· 1.利用byte陣列作為一個緩衝區進行讀寫 客戶端上傳 1 //獲取

java網路程式設計tcp協議之backlog引數詳解

backlog是ServerSocket類中的引數，用來指定ServerSocket中等待客戶端連線佇列的最大數量，並且每呼叫一次

java網路程式設計tcp協議之setSoTimeout

該引數表明了socket從輸入流獲取資料的超時時間以毫秒為單位，只要雙方建立了連線不管是服務端還是客戶端，也不管對方有沒有往輸入流

java網路程式設計tcp協議之setKeepAlive

keepAlive是socket連線在沒有資料交換時用來探測連線是否存活的一種心跳機制。當然也可以自己實現心跳機制而不使用自帶的功

java網路程式設計tcp協議之setSoLinger

setSoLinger是當socket在關閉時對當前未傳送給對方資料的一種控制方式。 1、setSoLinger(true, 0

GO語言使用之網路程式設計(TCP程式設計)

一、基本介紹 Golang的主要設計目標之一就是面向大規模後端服務程式，網路通訊這塊是服務端 程式必不可少也是至關重要的一部分。 1、 網路程式設計有兩種: 1) TCP socket程式設計，是網路程式設計的主流。之所以叫Tcp socket程式設計，是因為底層是基於Tcp/i

Java基礎語言程式設計 第六章 一維陣列

一維陣列的定義 1 陣列的定義：    陣列是用來儲存資料的集合，通常把陣列看作一個儲存具有相同型別的變數集合會更有用。 2 宣告陣列變數   為了在程式中使用陣列，必須宣告一個引用陣列的變數，並指明陣列的元素型別。下面是宣告陣列變數的語法：   elementType[]a

Java基礎--併發程式設計

JAVA併發程式設計第一步：瞭解Java虛擬機器提供的API操作，以及執行緒基本概念的操作： 1：定義執行緒 -- 繼承Thread類和實現Runnable方法 1 /** 2 * 定義執行緒 1:繼承Thread類，方法、形式如下 3 */ 4 public s

初步接觸 Java Net 網路程式設計

本文目的是大概瞭解 Java 網路程式設計體系，需要一點點 Java IO 基礎，推薦教程 系統學習 Java IO。主要參考 JavaDoc 和 Jakob Jenkov 的英文教程《Java Networking》 http://tutorials.jenkov.com/java-networking/i

java----day31(網路程式設計)

網路通訊協議 通過計算機網路可以使多臺計算機實現連線，位於同一個網路中的計算機在進行連線和通訊時需要遵守一定的規則，這就好比在道路中行駛的汽車一定要遵守交通規則一樣。在計算機網路中，這些連線和通訊的規則被稱為網路通訊協議，它對資料的傳輸格式、傳輸速率、傳輸步驟等做了統一規定，通訊雙方必須同時遵守