#手写聊天室
构建一个聊天室
如何能构建一个小型的聊天室呢,今天狗头哥哥给你们带来了一个小型聊天室的构建!
基于UDP的小型聊天室
一.创建传输方udptalk
``
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
public class udptalk implements Runnable {
DatagramSocket datagramSocket = null;
BufferedReader bufferedReader = null;
private int fromport;
private String toip;
private int toport;
public udptalk(int fromport, String toip, int toport) {
this.fromport = fromport;
this.toip = toip;
this.toport = toport;
try {
datagramSocket = new DatagramSocket(fromport);
bufferedReader = new BufferedReader(new InputStreamReader(System.in));
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while (true) {
String data = null;
try {
data = bufferedReader.readLine();
byte[] datas = data.getBytes();
DatagramPacket datagramPacket = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress(this.toip, this.toport));
datagramSocket.send(datagramPacket);
if(data.equals("baibai")){
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
datagramSocket.close();
}
}
二.接收方udptalk2的创建
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class udptalk2 implements Runnable{
DatagramSocket datagramSocket = null;
private int port;
private String info;
public udptalk2(int port,String info) {
this.port = port;
this.info = info;
try {
datagramSocket = new DatagramSocket(port);
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while (true) {
try {
byte[] data = new byte[10];
DatagramPacket datagramPacket = new DatagramPacket(data, 0, data.length);
datagramSocket.receive(datagramPacket);
byte[] datas = datagramPacket.getData();
String s = new String(datas, 0, datas.length);
System.out.println(info +":"+s);
if (s.equals("baibai")) {
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
datagramSocket.close();
}
}
三.多线程双方的实现学生和老师
public class Student {
public static void main(String[] args) {
new Thread(new udptalk(666,"localhost",888)).start();
new Thread(new udptalk2(999,"老师")).start();
}
}
public class Teacher {
public static void main(String[] args) {
new Thread(new udptalk(333,"localhost",999)).start();
new Thread(new udptalk2(888,"学生")).start();
}
}
四.测试运行学生端和老师端
student向teacher发送hello,teacher接受并给student发送hello
今天的分享就到这里,有帮助的帮忙点赞分享!谢谢大家。