java 中模擬TCP傳輸?shù)目蛻舳撕头?wù)端實(shí)例詳解
一、創(chuàng)建TCP傳輸?shù)目蛻舳?/strong>
1、建立TCP客戶端的Socket服務(wù),使用的是Socket對(duì)象,建議該對(duì)象一創(chuàng)建就明確目的地,即要連接的主機(jī);
2、如果連接建立成功,說(shuō)明數(shù)據(jù)傳輸通道已建立,該通道就是Socket流,是底層建立好的,既然是流,說(shuō)著這里既有輸入流,又有輸出流,想要輸入流或者輸出流對(duì)象,可以通過(guò)Socket來(lái)獲取,可以通過(guò)getOutputStream()和getInputStream()來(lái)獲取;
3、使用輸出流,將數(shù)據(jù)寫出;
4、關(guān)閉Socket服務(wù)。
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服務(wù)
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、關(guān)閉Socket服務(wù)
socket.close();
}
}
二、創(chuàng)建TCP傳輸?shù)姆?wù)端
1、建立TCP服務(wù)端的的Socket服務(wù),通過(guò)ServerSocket對(duì)象;
2、服務(wù)端必須對(duì)外提供一個(gè)端口,否則客戶端無(wú)法連接;
3、獲取連接過(guò)來(lái)的客戶端對(duì)象;
4、通過(guò)客戶端對(duì)象來(lái)獲取Socket流,讀取客戶端發(fā)來(lái)的數(shù)據(jù);
5、關(guān)閉資源,關(guān)客戶端,關(guān)服務(wù)端。
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)建客戶端對(duì)象
ServerSocket ss = new ServerSocket(10002);
// 2、獲取連接過(guò)來(lái)的客戶端對(duì)象
Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
// 3、通過(guò)Socket對(duì)象獲取輸入流,讀取客戶端發(fā)來(lái)的數(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、關(guān)閉資源
s.close();
ss.close();
}
}
三、優(yōu)化TCP傳輸?shù)目蛻舳撕头?wù)端
在本部分,我們對(duì)前兩部分的內(nèi)容進(jìn)行優(yōu)化,實(shí)現(xiàn)TCP傳輸模式下的客戶端和服務(wù)端的交互功能。
/**
*優(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());
// 讀取服務(wù)端返回的數(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ù)姆?wù)端
*/
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)建服務(wù)端對(duì)象
ServerSocket ss = new ServerSocket(10002);
// 2、獲取連接過(guò)來(lái)的客戶端對(duì)象
Socket s = ss.accept(); //accept方式為阻塞式方法
String ip = s.getInetAddress().getHostAddress();
// 3、通過(guò)Socket對(duì)象獲取輸入流,要讀取客戶端發(fā)來(lái)的數(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對(duì)象的輸出流給客戶端返回?cái)?shù)據(jù)
OutputStream out = s.getOutputStream();
out.write("收到".getBytes());
s.close();
ss.close();
}
}
四、創(chuàng)建英文大寫轉(zhuǎn)換服務(wù)器
應(yīng)用TCP(Transmission Control Protocol,傳輸控制協(xié)議)的相關(guān)性質(zhì),創(chuàng)建一個(gè)基于TCP傳輸下的英文大寫轉(zhuǎn)換服務(wù)器,要求:客戶端輸入字母數(shù)據(jù),發(fā)送給服務(wù)端;服務(wù)端收到數(shù)據(jù)后顯示在控制臺(tái),并將該數(shù)據(jù)轉(zhuǎn)成大寫字母返回給客戶端;直到客戶端輸入“over”為止,轉(zhuǎn)換結(jié)束。
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客戶端對(duì)象
* 2、獲取鍵盤錄入的數(shù)據(jù)
* 3、將錄入的信息發(fā)送給Socket輸出流
* 4、讀取服務(wù)端的數(shù)據(jù)并返回的大寫數(shù)據(jù)
*/
// 1、創(chuàng)建Socket客戶端對(duì)象
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輸入流,讀取服務(wù)端的數(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);
// 讀取服務(wù)端返回的一行大寫數(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)建服務(wù)端
* 1、創(chuàng)建SeverSocket客戶端對(duì)象
* 2、獲取Socket流
* 3、通過(guò)Socket, 讀取客戶端發(fā)過(guò)來(lái)的需要轉(zhuǎn)換的數(shù)據(jù)
* 4、顯示在控制臺(tái)上
* 5、將數(shù)據(jù)轉(zhuǎn)換成大寫返回給客戶端
*/
// 1、創(chuàng)建SeverSocket對(duì)象
ServerSocket ss = new ServerSocket(10004);
// 2、獲取Socket對(duì)象
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();
}
}
感謝閱讀,希望能幫助到大家,謝謝大家對(duì)本站的支持!
- 實(shí)現(xiàn)了基于TCP的Java Socket編程實(shí)例代碼
- Java實(shí)現(xiàn)Socket的TCP傳輸實(shí)例
- java實(shí)現(xiàn)一個(gè)簡(jiǎn)單TCPSocket聊天室功能分享
- Java基于Tcp協(xié)議的socket編程實(shí)例
- 基于java TCP網(wǎng)絡(luò)通信的實(shí)例詳解
- Java基于TCP方式的二進(jìn)制文件傳輸
- Java Socket編程實(shí)例(四)- NIO TCP實(shí)踐
- Java Socket編程實(shí)例(三)- TCP服務(wù)端線程池
- Java使用TCP實(shí)現(xiàn)數(shù)據(jù)傳輸實(shí)例詳解
- Java網(wǎng)絡(luò)編程之TCP程序設(shè)計(jì)
相關(guān)文章
基于Java實(shí)現(xiàn)的一層簡(jiǎn)單人工神經(jīng)網(wǎng)絡(luò)算法示例
這篇文章主要介紹了基于Java實(shí)現(xiàn)的一層簡(jiǎn)單人工神經(jīng)網(wǎng)絡(luò)算法,結(jié)合實(shí)例形式分析了java實(shí)現(xiàn)人工神經(jīng)網(wǎng)絡(luò)的具體實(shí)現(xiàn)技巧,需要的朋友可以參考下2017-12-12
詳解JDBC對(duì)Mysql utf8mb4字符集的處理
這篇文章主要介紹了詳解JDBC對(duì)Mysql utf8mb4字符集的處理,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-11-11
JavaWeb 實(shí)現(xiàn)多個(gè)文件壓縮下載功能
文件下載時(shí),我們可能需要一次下載多個(gè)文件,批量下載文件時(shí),需要將多個(gè)文件打包為zip,然后再下載。本文給大家分享實(shí)現(xiàn)思路及具體實(shí)現(xiàn)代碼,對(duì)javaweb實(shí)現(xiàn)文件壓縮下載功能感興趣的朋友一起學(xué)習(xí)吧2017-07-07
MyBatis中多對(duì)一和一對(duì)多數(shù)據(jù)的處理方法
這篇文章主要介紹了MyBatis中多對(duì)一和一對(duì)多數(shù)據(jù)的處理,本文通過(guò)示例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-01-01
詳解Java的Hibernat框架中的Map映射與SortedMap映射
這篇文章主要介紹了Java的Hibernat框架中的Map映射與SortedMap映射,Hibernat是Java的SSH三大web開(kāi)發(fā)框架之一,需要的朋友可以參考下2015-12-12
SpringBoot如何注冊(cè)Servlet、Filter、Listener的幾種方式
在Servlet 3.0之前都是使用web.xml文件進(jìn)行配置,這篇文章主要介紹了SpringBoot如何注冊(cè)Servlet、Filter、Listener的幾種方式,在Servlet 3.0之前都是使用web.xml文件進(jìn)行配置,2018-10-10
SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法
說(shuō)起多數(shù)據(jù)源,一般都來(lái)解決那些問(wèn)題呢,主從模式或者業(yè)務(wù)比較復(fù)雜需要連接不同的分庫(kù)來(lái)支持業(yè)務(wù)。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法,感興趣的可以了解一下,感興趣的可以額了解一下2021-12-12

