本文实例为大家分享了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编写局域网多人聊天室
- 使用Java和WebSocket实现网页聊天室实例代码
- Java基于socket实现简易聊天室实例
- 基于Java Socket实现一个简易在线聊天功能(一)
- java中UDP简单聊天程序实例代码
- 网页版在线聊天java Socket实现
- java实现一个简单TCPSocket聊天室功能分享
- java网络编程学习java聊天程序代码分享
- Java Socket聊天室编程(一)之利用socket实现聊天之消息推送
- java Socket简易聊天工具