欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

基于UDP實現(xiàn)聊天室功能

 更新時間:2021年04月20日 11:59:14   作者:ZJH_CZ  
這篇文章主要為大家詳細(xì)介紹了基于UDP實現(xiàn)聊天室功能,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下

本文實例為大家分享了UDP實現(xiàn)聊天室功能的具體代碼,供大家參考,具體內(nèi)容如下

項目結(jié)構(gòu)

data.java

package udp;

import java.net.InetAddress;

public class data {
 InetAddress Address;
 int Port;
 public InetAddress getAddress() {
  return Address;
 }
 public void setAddress(InetAddress address) {
  Address = address;
 }
 public int getPort() {
  return Port;
 }
 public void setPort(int port) {
  Port = port;
 }
}

服務(wù)器端

Server.java

package udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.ArrayList;

public class Server {
 DatagramSocket socket = null; 
 ArrayList<data> client;
 
 public Server() { 
  try {
   socket = new DatagramSocket(8888);
  } catch (SocketException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  client = new ArrayList<data>();
 }
 
 public void s_r(){
  try {
   
   while(true) {
    byte[] buf = new byte[3000];
    //接收數(shù)據(jù)的數(shù)據(jù)包
    DatagramPacket packet = new DatagramPacket(buf,buf.length);
    socket.receive(packet);
    //地址
    InetAddress clientAddress = packet.getAddress();
    //端口號    
    int clientPort = packet.getPort();
    data d = new data();
    d.setAddress(clientAddress);
    d.setPort(clientPort);
    int i=0;
    //判斷客戶端集合里是否存在發(fā)送新消息的客戶端
    for(;i<client.size();i++) {
     if(client.get(i).getAddress().equals(clientAddress)&&client.get(i).getPort()==clientPort) {
      break;
     }
    }
    if(i==client.size()) {
     client.add(d);
    }
    String s=new String(packet.getData()).trim()+"來自:"+clientAddress.getHostAddress()+":"+clientPort;
    System.out.println(s);
    //把信息發(fā)給每個客戶端
    for(data c:client) {
     try {
      //地址
      InetAddress cAddress = c.getAddress();
      //端口號
      int cPort = c.getPort();
      
      buf = s.getBytes();
      //創(chuàng)建要發(fā)送的數(shù)據(jù)包
      packet = new DatagramPacket(buf,buf.length,cAddress,cPort);
      socket.send(packet);
      } catch (IOException e) {
       // TODO Auto-generated catch block
       e.printStackTrace();
      }
     }    
   }
  } catch (SocketException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }finally {
   if(socket!=null)socket.close();
  }
  
 }  
 public static void main(String[] args) {
  Server s = new Server();
  s.s_r();
 }
}

客戶端

package udp;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;

public class Client {
 DatagramSocket socket = null;
 DatagramPacket packet;
 InetAddress address = null;
 Client(){
  try {
   socket = new DatagramSocket();
  } catch (SocketException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }  
 }
 
 public void s_r() {
  try {
   // 把表示服務(wù)器端IP地址的字符串轉(zhuǎn)換成InetAddress對象
   address = InetAddress.getByName("127.0.0.1");
   } catch (UnknownHostException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }  
  String s = "登陸";
  byte[] b = s.getBytes();
  packet = new DatagramPacket(b,b.length,address,8888);
  try {
   socket.send(packet);
  } catch (IOException e1) {
   // TODO Auto-generated catch block
   e1.printStackTrace();
  }

  //發(fā)送消息的線程
   new Thread(new Runnable() {
    @Override
    public void run() {
     // TODO Auto-generated method stub
     String sendStr;
     BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
     try {
      while((sendStr = stdIn.readLine())!=null) {
       byte[] buf = sendStr.getBytes();
       packet = new DatagramPacket(buf,buf.length,address,8888);
       socket.send(packet);
      }
     } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }     
    }
    
   }).start();

   //接收消息的線程
   new Thread(new Runnable() {

    @Override
    public void run() {
     // TODO Auto-generated method stub
     byte[] buf_1 = new byte[3000];
     // 使用空字節(jié)數(shù)組構(gòu)造空數(shù)據(jù)包
     DatagramPacket packet = new DatagramPacket(buf_1,buf_1.length);
     try {
       while(true) {
        socket.receive(packet);
        String received = new String(packet.getData(),0,packet.getLength()).trim();
        System.out.println("接收到的信息:"+received); 
       }
          
     } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }
    }
   }).start();
 }
 
 public static void main(String[] args) {
  Client c = new Client();
  c.s_r();
 } 
}

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • Spring?AOP實現(xiàn)聲明式事務(wù)機制源碼解析

    Spring?AOP實現(xiàn)聲明式事務(wù)機制源碼解析

    這篇文章主要為大家介紹了Spring?AOP實現(xiàn)聲明式事務(wù)機制源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-12-12
  • Springboot項目中如何讓非Spring管理的類獲得一個注入的Bean

    Springboot項目中如何讓非Spring管理的類獲得一個注入的Bean

    這篇文章主要介紹了Springboot項目中如何讓非Spring管理的類獲得一個注入的Bean問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-12-12
  • 在spring中手寫全局異常攔截器

    在spring中手寫全局異常攔截器

    這篇文章主要介紹了如何在spring中手寫全局異常攔截器,幫助大家更好的理解和使用spring框架,感興趣的朋友可以了解下
    2020-11-11
  • java集合與數(shù)組的相同點和不同點

    java集合與數(shù)組的相同點和不同點

    今天小編就為大家分享一篇關(guān)于java集合與數(shù)組的相同點和不同點,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2019-04-04
  • 解析Spring中的靜態(tài)代理和動態(tài)代理

    解析Spring中的靜態(tài)代理和動態(tài)代理

    學(xué)習(xí) Spring 的過程中,不可避免要掌握代理模式。這篇文章總結(jié)一下代理模式。顧名思義,代理,就是你委托別人幫你辦事,所以代理模式也有人稱作委托模式的。比如領(lǐng)導(dǎo)要做什么事,可以委托他的秘書去幫忙做,這時就可以把秘書看做領(lǐng)導(dǎo)的代理
    2021-06-06
  • 深入理解java中的拷貝機制

    深入理解java中的拷貝機制

    這篇文章主要給大家深入介紹了java中的拷貝機制,網(wǎng)上關(guān)于java中拷貝的文章也很多,但覺得有必要再深的介紹下java的拷貝機制,有需要的朋友可以參考學(xué)習(xí),下面來一起看看吧。
    2017-02-02
  • Intellij無法創(chuàng)建java文件解決方案

    Intellij無法創(chuàng)建java文件解決方案

    這篇文章主要介紹了Intellij無法創(chuàng)建java文件解決方案,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-10-10
  • javaweb啟動時啟動socket服務(wù)端代碼實現(xiàn)

    javaweb啟動時啟動socket服務(wù)端代碼實現(xiàn)

    這篇文章主要介紹了javaweb啟動時啟動socket服務(wù)端代碼實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-11-11
  • Java中GC的工作原理詳細(xì)介紹

    Java中GC的工作原理詳細(xì)介紹

    這篇文章主要介紹了Java中GC的工作原理詳細(xì)介紹的相關(guān)資料,需要的朋友可以參考下
    2017-03-03
  • 淺談Java分布式架構(gòu)下如何實現(xiàn)分布式鎖

    淺談Java分布式架構(gòu)下如何實現(xiàn)分布式鎖

    這篇文章主要介紹了淺談Java分布式架構(gòu)下如何實現(xiàn)分布式鎖,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-07-07

最新評論