欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java实现简易局域网聊天功能

程序员文章站 2023-12-03 09:39:28
本文实例为大家分享了java使用udp模式编写聊天程序的具体代码,供大家参考,具体内容如下 java代码: /* 使用udp模式,编写一个聊天程序 有发...

本文实例为大家分享了java使用udp模式编写聊天程序的具体代码,供大家参考,具体内容如下

java代码:

/* 
使用udp模式,编写一个聊天程序 
有发送和接收数据2部分, 
一个线程接收,一个线程发送 
 
由于发送和接收动作是不一致的,所以要使用2个run方法 
而且这两个方法要封装到不同的类中 
 
本程序忽略了部分异常的处理,也未加入ui组件 
这样比较简洁 
 
发送端口9998 
接受端口9999 
用的是局域网广播地址,所以自己发的消息自己也收到了 
 
[示例]:简易控制台聊天程序 
*/ 
import java.net.*; 
import java.io.*; 
class demo 
{ 
 public static void main(string[] args) throws exception 
 { 
  datagramsocket sendsocket = new datagramsocket(9998); //发送端 
  datagramsocket recesocket = new datagramsocket(9999); //接收端 
  new thread(new msgsend(sendsocket)).start();      //发送线程 
  new thread(new msgrece(recesocket)).start();      //接受线程 
 } 
} 
 
class msgsend implements runnable   //发送 
{ 
 private datagramsocket dsock; 
 public msgsend(datagramsocket dsock) 
 { 
  this.dsock= dsock; 
 } 
 
 public void run() 
 { 
  bufferedreader bufr = new bufferedreader(new inputstreamreader(system.in)); 
  string linestr = null; 
  try 
  {     
   while(true) 
   { 
    linestr = bufr.readline(); 
    if(linestr!=null) 
    { 
     if(linestr.equals("over886")) 
     { 
      break; 
     } 
     else 
     { 
      byte[] databuf = linestr.getbytes(); 
      datagrampacket datapack =  //数据打包 
      new datagrampacket( databuf, 
                databuf.length, 
                inetaddress.getbyname("192.168.1.255"), //广播 
                9999 //目标端口 
               ); 
      dsock.send(datapack); 
     } 
    } 
   } 
   bufr.close(); 
   dsock.close(); 
  } 
  catch(exception e) 
  { 
   throw new runtimeexception("发送失败!"); 
  } 
 } 
} 
 
class msgrece implements runnable  //接收 
{ 
 private datagramsocket dsock; 
 public msgrece(datagramsocket dsock) 
 { 
  this.dsock= dsock; 
 } 
 
 public void run() 
 { 
  try 
  { 
   while(true) 
   { 
     byte[] databuf = new byte[1024]; 
     datagrampacket datapack = new datagrampacket(databuf,databuf.length); 
     dsock.receive(datapack); //将获取的数据保存到指定的数据包 
     string ip = datapack.getaddress().gethostaddress(); 
     string data = new string(datapack.getdata(),0,datapack.getlength()); 
     int port = datapack.getport(); 
     system.out.println();  
     system.out.println("来自ip为 "+ip+" <对方端口>: "+port+" 的消息"); 
     system.out.println(data);     
   } 
  } 
  catch(exception e) 
  { 
   throw new runtimeexception("接受失败!"); 
  } 
  finally 
  { 
   dsock.close(); 
  } 
 } 
} 

java实现简易局域网聊天功能

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。