java 中模擬TCP傳輸?shù)目蛻舳撕头斩藢嵗斀?/h1>
更新時間:2017年03月28日 09:39:24 投稿:lqh
這篇文章主要介紹了java 中模擬TCP傳輸?shù)目蛻舳撕头斩藢嵗斀獾南嚓P資料,需要的朋友可以參考下
一、創(chuàng)建TCP傳輸?shù)目蛻舳?/strong>
1、建立TCP客戶端的Socket服務,使用的是Socket對象,建議該對象一創(chuàng)建就明確目的地,即要連接的主機;
2、如果連接建立成功,說明數(shù)據(jù)傳輸通道已建立,該通道就是Socket流,是底層建立好的,既然是流,說著這里既有輸入流,又有輸出流,想要輸入流或者輸出流對象,可以通過Socket來獲取,可以通過getOutputStream()和getInputStream()來獲??;
3、使用輸出流,將數(shù)據(jù)寫出;
4、關閉Socket服務。
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
public class Client {
public static void main(String[] args) throws IOException {
// 1、創(chuàng)建客戶端的Socket服務
Socket socket = new Socket("192.168.1.100", 10002);
// 2、獲取Socket流中輸入流
OutputStream out = socket.getOutputStream();
// 3、使用輸出流將指定的數(shù)據(jù)寫出去
out.write("TCP is coming !".getBytes());
// 4、關閉Socket服務
socket.close();
}
}
二、創(chuàng)建TCP傳輸?shù)姆斩?/strong>
1、建立TCP服務端的的Socket服務,通過ServerSocket對象;
2、服務端必須對外提供一個端口,否則客戶端無法連接;
3、獲取連接過來的客戶端對象;
4、通過客戶端對象來獲取Socket流,讀取客戶端發(fā)來的數(shù)據(jù);
5、關閉資源,關客戶端,關服務端。
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) throws IOException {
// 1、創(chuàng)建客戶端對象
ServerSocket ss = new ServerSocket(10002);
// 2、獲取連接過來的客戶端對象
Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
// 3、通過Socket對象獲取輸入流,讀取客戶端發(fā)來的數(shù)據(jù)
InputStream in = s.getInputStream();
byte[] buf = new byte[1024];
int len = in.read(buf);
String text = new String(buf, 0, len);
System.out.println(ip + ":" + text);
// 4、關閉資源
s.close();
ss.close();
}
}
三、優(yōu)化TCP傳輸?shù)目蛻舳撕头斩?/strong>
在本部分,我們對前兩部分的內容進行優(yōu)化,實現(xiàn)TCP傳輸模式下的客戶端和服務端的交互功能。
/**
*優(yōu)化TCP傳輸?shù)目蛻舳?
*/
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class ClientUpdate {
public static void main(String[] args) throws IOException {
Socket socket = new Socket("192.168.1.100", 10002);
OutputStream out = socket.getOutputStream();
out.write("tcp!".getBytes());
// 讀取服務端返回的數(shù)據(jù),使用Socket讀取流
InputStream in = socket.getInputStream();
byte[] buf = new byte[1024];
int len = in.read(buf);
String text = new String(buf, 0, len);
System.out.println(text);
socket.close();
}
}
/**
*優(yōu)化TCP傳輸?shù)姆斩?
*/
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerUpdate {
public static void main(String[] args) throws IOException {
// 1、創(chuàng)建服務端對象
ServerSocket ss = new ServerSocket(10002);
// 2、獲取連接過來的客戶端對象
Socket s = ss.accept(); //accept方式為阻塞式方法
String ip = s.getInetAddress().getHostAddress();
// 3、通過Socket對象獲取輸入流,要讀取客戶端發(fā)來的數(shù)據(jù)
InputStream in = s.getInputStream();
byte[] buf = new byte[1024];
int len = in.read(buf);
String text = new String(buf, 0, len);
System.out.println(ip + ":" + text);
// 使用客戶端的Socket對象的輸出流給客戶端返回數(shù)據(jù)
OutputStream out = s.getOutputStream();
out.write("收到".getBytes());
s.close();
ss.close();
}
}
四、創(chuàng)建英文大寫轉換服務器
應用TCP(Transmission Control Protocol,傳輸控制協(xié)議)的相關性質,創(chuàng)建一個基于TCP傳輸下的英文大寫轉換服務器,要求:客戶端輸入字母數(shù)據(jù),發(fā)送給服務端;服務端收到數(shù)據(jù)后顯示在控制臺,并將該數(shù)據(jù)轉成大寫字母返回給客戶端;直到客戶端輸入“over”為止,轉換結束。
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class TransClient {
public static void main(String[] args) throws IOException {
/**
* 思路:創(chuàng)建客戶端
* 1、創(chuàng)建Socket客戶端對象
* 2、獲取鍵盤錄入的數(shù)據(jù)
* 3、將錄入的信息發(fā)送給Socket輸出流
* 4、讀取服務端的數(shù)據(jù)并返回的大寫數(shù)據(jù)
*/
// 1、創(chuàng)建Socket客戶端對象
Socket s = new Socket("192.168.1.100", 10004);
// 2、獲取鍵盤錄入
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
// 3、Socket輸出流
PrintWriter out = new PrintWriter(s.getOutputStream(), true);
// 4、Socket輸入流,讀取服務端的數(shù)據(jù)并返回的大寫數(shù)據(jù)
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
String line = null;
while ((line = bufr.readLine()) != null) {
if ("over".equals(line))
break;
out.println(line);
// 讀取服務端返回的一行大寫數(shù)據(jù)
String upperStr = bufIn.readLine();
System.out.println(upperStr);
}
s.close();
}
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class TransServer {
public static void main(String[] args) throws IOException {
/**
* 思路:創(chuàng)建服務端
* 1、創(chuàng)建SeverSocket客戶端對象
* 2、獲取Socket流
* 3、通過Socket, 讀取客戶端發(fā)過來的需要轉換的數(shù)據(jù)
* 4、顯示在控制臺上
* 5、將數(shù)據(jù)轉換成大寫返回給客戶端
*/
// 1、創(chuàng)建SeverSocket對象
ServerSocket ss = new ServerSocket(10004);
// 2、獲取Socket對象
Socket s = ss.accept();
// 獲取IP地址
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip + "......connected");
// 3、獲取Socket讀取流,并裝飾
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
// 4、獲取Socket的輸出流,并裝飾
PrintWriter out = new PrintWriter(s.getOutputStream(), true);
String line = null;
while ((line = bufIn.readLine()) != null) {
System.out.println(line);
out.println(line.toUpperCase());
}
s.close();
ss.close();
}
}
感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!
相關文章
-
基于Java實現(xiàn)的一層簡單人工神經(jīng)網(wǎng)絡算法示例
這篇文章主要介紹了基于Java實現(xiàn)的一層簡單人工神經(jīng)網(wǎng)絡算法,結合實例形式分析了java實現(xiàn)人工神經(jīng)網(wǎng)絡的具體實現(xiàn)技巧,需要的朋友可以參考下 2017-12-12
-
MyBatis中多對一和一對多數(shù)據(jù)的處理方法
這篇文章主要介紹了MyBatis中多對一和一對多數(shù)據(jù)的處理,本文通過示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下 2023-01-01
-
詳解Java的Hibernat框架中的Map映射與SortedMap映射
這篇文章主要介紹了Java的Hibernat框架中的Map映射與SortedMap映射,Hibernat是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下 2015-12-12
-
SpringBoot如何注冊Servlet、Filter、Listener的幾種方式
在Servlet 3.0之前都是使用web.xml文件進行配置,這篇文章主要介紹了SpringBoot如何注冊Servlet、Filter、Listener的幾種方式,在Servlet 3.0之前都是使用web.xml文件進行配置, 2018-10-10
-
SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法
說起多數(shù)據(jù)源,一般都來解決那些問題呢,主從模式或者業(yè)務比較復雜需要連接不同的分庫來支持業(yè)務。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法,感興趣的可以了解一下,感興趣的可以額了解一下 2021-12-12
最新評論
一、創(chuàng)建TCP傳輸?shù)目蛻舳?/strong>
1、建立TCP客戶端的Socket服務,使用的是Socket對象,建議該對象一創(chuàng)建就明確目的地,即要連接的主機;
2、如果連接建立成功,說明數(shù)據(jù)傳輸通道已建立,該通道就是Socket流,是底層建立好的,既然是流,說著這里既有輸入流,又有輸出流,想要輸入流或者輸出流對象,可以通過Socket來獲取,可以通過getOutputStream()和getInputStream()來獲??;
3、使用輸出流,將數(shù)據(jù)寫出;
4、關閉Socket服務。
import java.io.IOException; import java.io.OutputStream; import java.net.Socket; public class Client { public static void main(String[] args) throws IOException { // 1、創(chuàng)建客戶端的Socket服務 Socket socket = new Socket("192.168.1.100", 10002); // 2、獲取Socket流中輸入流 OutputStream out = socket.getOutputStream(); // 3、使用輸出流將指定的數(shù)據(jù)寫出去 out.write("TCP is coming !".getBytes()); // 4、關閉Socket服務 socket.close(); } }
二、創(chuàng)建TCP傳輸?shù)姆斩?/strong>
1、建立TCP服務端的的Socket服務,通過ServerSocket對象;
2、服務端必須對外提供一個端口,否則客戶端無法連接;
3、獲取連接過來的客戶端對象;
4、通過客戶端對象來獲取Socket流,讀取客戶端發(fā)來的數(shù)據(jù);
5、關閉資源,關客戶端,關服務端。
import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) throws IOException { // 1、創(chuàng)建客戶端對象 ServerSocket ss = new ServerSocket(10002); // 2、獲取連接過來的客戶端對象 Socket s = ss.accept(); String ip = s.getInetAddress().getHostAddress(); // 3、通過Socket對象獲取輸入流,讀取客戶端發(fā)來的數(shù)據(jù) InputStream in = s.getInputStream(); byte[] buf = new byte[1024]; int len = in.read(buf); String text = new String(buf, 0, len); System.out.println(ip + ":" + text); // 4、關閉資源 s.close(); ss.close(); } }
三、優(yōu)化TCP傳輸?shù)目蛻舳撕头斩?/strong>
在本部分,我們對前兩部分的內容進行優(yōu)化,實現(xiàn)TCP傳輸模式下的客戶端和服務端的交互功能。
/** *優(yōu)化TCP傳輸?shù)目蛻舳? */ import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; public class ClientUpdate { public static void main(String[] args) throws IOException { Socket socket = new Socket("192.168.1.100", 10002); OutputStream out = socket.getOutputStream(); out.write("tcp!".getBytes()); // 讀取服務端返回的數(shù)據(jù),使用Socket讀取流 InputStream in = socket.getInputStream(); byte[] buf = new byte[1024]; int len = in.read(buf); String text = new String(buf, 0, len); System.out.println(text); socket.close(); } }
/** *優(yōu)化TCP傳輸?shù)姆斩? */ import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class ServerUpdate { public static void main(String[] args) throws IOException { // 1、創(chuàng)建服務端對象 ServerSocket ss = new ServerSocket(10002); // 2、獲取連接過來的客戶端對象 Socket s = ss.accept(); //accept方式為阻塞式方法 String ip = s.getInetAddress().getHostAddress(); // 3、通過Socket對象獲取輸入流,要讀取客戶端發(fā)來的數(shù)據(jù) InputStream in = s.getInputStream(); byte[] buf = new byte[1024]; int len = in.read(buf); String text = new String(buf, 0, len); System.out.println(ip + ":" + text); // 使用客戶端的Socket對象的輸出流給客戶端返回數(shù)據(jù) OutputStream out = s.getOutputStream(); out.write("收到".getBytes()); s.close(); ss.close(); } }
四、創(chuàng)建英文大寫轉換服務器
應用TCP(Transmission Control Protocol,傳輸控制協(xié)議)的相關性質,創(chuàng)建一個基于TCP傳輸下的英文大寫轉換服務器,要求:客戶端輸入字母數(shù)據(jù),發(fā)送給服務端;服務端收到數(shù)據(jù)后顯示在控制臺,并將該數(shù)據(jù)轉成大寫字母返回給客戶端;直到客戶端輸入“over”為止,轉換結束。
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class TransClient { public static void main(String[] args) throws IOException { /** * 思路:創(chuàng)建客戶端 * 1、創(chuàng)建Socket客戶端對象 * 2、獲取鍵盤錄入的數(shù)據(jù) * 3、將錄入的信息發(fā)送給Socket輸出流 * 4、讀取服務端的數(shù)據(jù)并返回的大寫數(shù)據(jù) */ // 1、創(chuàng)建Socket客戶端對象 Socket s = new Socket("192.168.1.100", 10004); // 2、獲取鍵盤錄入 BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in)); // 3、Socket輸出流 PrintWriter out = new PrintWriter(s.getOutputStream(), true); // 4、Socket輸入流,讀取服務端的數(shù)據(jù)并返回的大寫數(shù)據(jù) BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream())); String line = null; while ((line = bufr.readLine()) != null) { if ("over".equals(line)) break; out.println(line); // 讀取服務端返回的一行大寫數(shù)據(jù) String upperStr = bufIn.readLine(); System.out.println(upperStr); } s.close(); } }
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; public class TransServer { public static void main(String[] args) throws IOException { /** * 思路:創(chuàng)建服務端 * 1、創(chuàng)建SeverSocket客戶端對象 * 2、獲取Socket流 * 3、通過Socket, 讀取客戶端發(fā)過來的需要轉換的數(shù)據(jù) * 4、顯示在控制臺上 * 5、將數(shù)據(jù)轉換成大寫返回給客戶端 */ // 1、創(chuàng)建SeverSocket對象 ServerSocket ss = new ServerSocket(10004); // 2、獲取Socket對象 Socket s = ss.accept(); // 獲取IP地址 String ip = s.getInetAddress().getHostAddress(); System.out.println(ip + "......connected"); // 3、獲取Socket讀取流,并裝飾 BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream())); // 4、獲取Socket的輸出流,并裝飾 PrintWriter out = new PrintWriter(s.getOutputStream(), true); String line = null; while ((line = bufIn.readLine()) != null) { System.out.println(line); out.println(line.toUpperCase()); } s.close(); ss.close(); } }
感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!
相關文章
基于Java實現(xiàn)的一層簡單人工神經(jīng)網(wǎng)絡算法示例
這篇文章主要介紹了基于Java實現(xiàn)的一層簡單人工神經(jīng)網(wǎng)絡算法,結合實例形式分析了java實現(xiàn)人工神經(jīng)網(wǎng)絡的具體實現(xiàn)技巧,需要的朋友可以參考下2017-12-12MyBatis中多對一和一對多數(shù)據(jù)的處理方法
這篇文章主要介紹了MyBatis中多對一和一對多數(shù)據(jù)的處理,本文通過示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-01-01詳解Java的Hibernat框架中的Map映射與SortedMap映射
這篇文章主要介紹了Java的Hibernat框架中的Map映射與SortedMap映射,Hibernat是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12SpringBoot如何注冊Servlet、Filter、Listener的幾種方式
在Servlet 3.0之前都是使用web.xml文件進行配置,這篇文章主要介紹了SpringBoot如何注冊Servlet、Filter、Listener的幾種方式,在Servlet 3.0之前都是使用web.xml文件進行配置,2018-10-10SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法
說起多數(shù)據(jù)源,一般都來解決那些問題呢,主從模式或者業(yè)務比較復雜需要連接不同的分庫來支持業(yè)務。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實現(xiàn)方法,感興趣的可以了解一下,感興趣的可以額了解一下2021-12-12