午夜无码人妻aⅴ大片色欲张津瑜,国产69久久久欧美黑人A片,色妺妺视频网,久久久久国产综合AV天堂

Java簡(jiǎn)單實(shí)現(xiàn)UDP和TCP的示例

TCP實(shí)現(xiàn)

站在用戶的角度思考問題，與客戶深入溝通，找到伊犁網(wǎng)站設(shè)計(jì)與伊犁網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類型包括：成都網(wǎng)站制作、網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、主機(jī)域名、網(wǎng)站空間、企業(yè)郵箱。業(yè)務(wù)覆蓋伊犁地區(qū)。

TCP協(xié)議需要在雙方之間建立連接，通過輸入輸出流來進(jìn)行數(shù)據(jù)的交換，建立需要通過三次握手，斷開需要四次揮手，保證了數(shù)據(jù)的完整性，但傳輸效率也會(huì)相應(yīng)的降低。

Java簡(jiǎn)單實(shí)現(xiàn)UDP和TCP的示例

簡(jiǎn)單的TCP實(shí)現(xiàn)

//服務(wù)端
public class TcpServer {
 public static void main(String[] args) throws IOException {
  ServerSocket serverSocket = new ServerSocket(8886); // 建立服務(wù)端，ip為本機(jī)ip,端口為8886
  Socket accept = serverSocket.accept(); // 監(jiān)聽客戶端的連接，一旦有客戶端連接，則會(huì)返回客戶端對(duì)應(yīng)的accept
  
  InputStream in = accept.getInputStream(); //獲取到客戶端的輸出流
  byte b[] = new byte[1024];
  int len = in.read(b);
  System.out.println("接受到客戶端數(shù)據(jù),返回?cái)?shù)據(jù)"+new String(b,0,len)); 
  
  OutputStream out = accept.getOutputStream(); // 給客戶端發(fā)送消息
  out.write("服務(wù)端已經(jīng)接受".getBytes());
  
  serverSocket.close();
 }
}

// 客戶端
public class TcpClient {
 public static void main(String[] args) throws IOException {
  Socket socket = new Socket("127.0.0.1", 8886); // 通過Socket來建立和服務(wù)端的連接
  OutputStream out = socket.getOutputStream(); // 獲取輸出流（客戶端輸出流即向服務(wù)端輸出信息）
  out.write("hello tcp Server".getBytes()); // 輸出信息
  
  InputStream in = socket.getInputStream(); // 接受服務(wù)端的消息
  byte b[] = new byte[1024];
  int len = in.read(b);
  System.out.println("接受到服務(wù)器消息 ： "+new String(b,0,len)); // 輸出
  out.write("返回的的數(shù)據(jù)已經(jīng)收到 ".getBytes()); // 向服務(wù)器返回消息
  socket.close();
 }
}

改進(jìn)服務(wù)端，啟用多線程來接受客戶端的數(shù)據(jù)

// server
 public static void main(String[] args) throws IOException {
  ServerSocket serverSocket = new ServerSocket(8886); // 建立服務(wù)端，ip為本機(jī)ip,端口為8886
  int i=4;
  while(i>2){
   Socket accept = serverSocket.accept(); // 監(jiān)聽客戶端的連接，一旦有客戶端連接，則會(huì)返回客戶端對(duì)應(yīng)的accept
   
   ServerThread st = new ServerThread(accept); // 啟動(dòng)線程
   Thread th = new Thread(st);
   th.start();
  }
  serverSocket.close();
 }

// thread

public class ServerThread implements Runnable {
 private Socket accept;
 public ServerThread(Socket s) {
  this.accept = s;
 }
 public void run(){
  InputStream in;
  try {
   in = accept.getInputStream();
   byte b[] = new byte[1024];
   int len = in.read(b);
   System.out.println("接受到客戶端數(shù)據(jù),返回?cái)?shù)據(jù)" + new String(b, 0, len));
   OutputStream out = accept.getOutputStream(); // 給客戶端發(fā)送消息
   out.write("服務(wù)端已經(jīng)接受".getBytes());
  } catch (IOException e) {
   e.printStackTrace();
  } 
 }
}

傳遞圖片

// 服務(wù)端

public class Server {
 public static void main(String[] args) throws IOException {

  ServerSocket serverSocket = new ServerSocket(5555);
  Socket ss = serverSocket.accept();
  
  BufferedInputStream br = new BufferedInputStream(ss.getInputStream());

  BufferedOutputStream bw = new BufferedOutputStream(new FileOutputStream("copy.jpg")); // 寫出文件流
  
  byte b[] = new byte[1024];
  int len = 0;
 
  while ((len = br.read(b)) != -1) { // 寫出文件
   bw.write(b, 0, len);
   bw.flush(); // 別忘了刷新，要不然最后一塊緩沖區(qū)字符串會(huì)缺失
  }

  BufferedWriter bw2 = new BufferedWriter(new OutputStreamWriter(ss.getOutputStream())); // 輸出
  bw2.write("圖片傳輸成功");
  bw2.flush();
  
  bw.close();
  ss.close();
 }

}


// 客戶端

public class Client {
 public static void main(String[] args) throws UnknownHostException, IOException {
  Socket socket = new Socket("127.0.0.1", 5555);
  BufferedInputStream in = new BufferedInputStream(new FileInputStream("c.jpg"));

  BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream());

  byte b[] = new byte[1024];
  int len = 0;

  while ((len = in.read(b)) != -1) {
   out.write(b, 0, len);
   out.flush(); // 刷新緩沖區(qū) 要不然最后一塊緩沖區(qū)字符串會(huì)缺失
  }
  
  socket.shutdownOutput(); // 關(guān)閉流以后Server段才會(huì)接收道結(jié)束字符結(jié)束接受

  BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  String line;
  while ((line = br.readLine()) != null) {
   System.out.println(line);
  }
  
  in.close();
  socket.close();

 }

}

UDP實(shí)現(xiàn)

UDP是將數(shù)據(jù)打成數(shù)據(jù)包向?qū)Ψ桨l(fā)送，只關(guān)系是否發(fā)送成功，而不關(guān)心是否接收成功，傳輸速度快，但是可靠性低。

udp代碼實(shí)現(xiàn)

// 發(fā)送端
public class SendDemo {
 public static void main(String[] args) throws IOException {
  DatagramSocket ds = new DatagramSocket(); // 此類表示用來發(fā)送和接收數(shù)據(jù)報(bào)包的套接字。
  BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); // 鍵盤輸入
  String line = null;
  while ((line = br.readLine()) != null) {
   byte[] bytes = line.getBytes();
   DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("127.0.0.1"), 10005); // 數(shù)據(jù)包對(duì)象
   ds.send(dp);
   if ("886".equals(line)) { // 當(dāng)輸入886時(shí)結(jié)束發(fā)送
    break;
   }
  }
  ds.close();
 }

}


// 接收端

public class ReciveDemo {
 public static void main(String[] args) throws IOException {
  DatagramSocket ds = new DatagramSocket(10005); // 建立服務(wù)端
  byte bytes[] = new byte[1024];
  DatagramPacket dp = new DatagramPacket(bytes, bytes.length); // 建立數(shù)據(jù)包對(duì)象
  while (true) {
   ds.receive(dp); // 接受數(shù)據(jù)包
   byte[] data = dp.getData(); // 獲取數(shù)據(jù)
   String str = new String(data, 0, dp.getLength());
   if ("886".equals(str)) {
    break;
   }
   System.out.println(str);
  }
  ds.close();
 }
}

以上這篇Java簡(jiǎn)單實(shí)現(xiàn)UDP和TCP的示例就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持創(chuàng)新互聯(lián)。

分享題目：Java簡(jiǎn)單實(shí)現(xiàn)UDP和TCP的示例
當(dāng)前地址：http://www.ekvhdxd.cn/article4/ijidoe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站導(dǎo)航、軟件開發(fā)、做網(wǎng)站、品牌網(wǎng)站制作、定制開發(fā)、小程序開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

成都app開發(fā)公司