最近比较闲，一直在抽空回顾一些java方面的技术应用。
今天没什么事做，基于udp协议，写了一个非常简单的聊天室程序。
现在的工作，很少用到socket，也算是对java网络编程方面的一个简单回忆。
先看一下效果：
实现的效果可以说是非常非常简单，但还是可以简单的看到一个实现原理。
“聊天室001”的用户，小红和小绿相互聊了两句，“聊天室002”的小黑无人理会，在一旁寂寞着。
看一下代码实现：
1、首先是消息服务器的实现，功能很简单：•将客户端的信息(进入了哪一个聊天室等)进行登记；
•构造udp协议套接字对象，接受各个客户端发送的消息；
•解析消息内容，将聊天信息推送回对应聊天室的各个客户端；
package com.tsr.simplechat.receive_server;
import java.io.ioexception;
import .datagrampacket;
import .datagramsocket;
import .socketexception;
import java.util.arraylist;
import java.util.hashmap;
import com.google.gson.gson;
import com.tsr.simplechat.bean.messageentity;
import com.tsr.simplechat.client.chatclient;
//聊天服务器
public class chatserver extends thread {
// 程序占用端口号
private static final int port = 10000;
// 消息接受套接字对象
private static datagramsocket server = null;
// 字典对象(key：聊天室id，value：该聊天室下的客户端用户集合);
private static hashmap> groups = new hashmap>();
// 构造器
public chatserver() {
try {
// 消息接受套接字对象的构造初始化
server = new datagramsocket(port);
} catch (socketexception e) {
e.printstacktrace();
}
}
// 注册聊天室新登录用户
public static void logingroup(string groupid, chatclient client) {
// 通过聊天室id，获取该聊天室的所有在线用户
arraylist clients = groups.get(groupid);
if (clients == null) {
clients = new arraylist();
}
// 将此次进入聊天室的用户登记
clients.add(client);
// 更新聊天室信息
groups.put(groupid, clients);
}
// 循环接收消息
@override
public void run() {
while (true) {
receivemessage();
}
}
private void receivemessage() {
// udp数据包
byte[] buf = new byte[1024];
datagrampacket packet = new datagrampacket(buf, buf.length);
while (true) {
try {
// 接受数据包
server.receive(packet);
} catch (ioexception e) {
// todo auto-generated catch block
e.printstacktrace();
}
// 解析数据包，获取聊天信息
string content = new string(packet.getdata(), 0, packet.getlength());
// 通过第三方包解析json数据
gson gson = new gson();
messageentity me = gson.fromjson(content, messageentity.class);
// 解析消息内容，通过聊天室id，获取该聊天室的所有在线用户
arraylist clients = groups.get(me.getgroupid());
// 将接收到的消息推送回该聊天室的各个用户
for (chatclient client : clients) {
client.pushbackmessage(me);
}
}
}
}
2、客户端程序，依然很简单：
•简单的定义客户端聊天室界面。
•构造消息发送套接字对象。
•获取聊天信息框的内容，发送到服务器。
package com.tsr.simplechat.client;
import java.awt.button;
import java.awt.event;
import java.awt.frame;
import java.awt.textarea;
import java.awt.textfield;
import java.awt.event.windowadapter;
import java.awt.event.windowevent;
import java.io.ioexception;
import .datagrampacket;
import .datagramsocket;
import .inetaddress;
import .socketexception;
import .unknownhostexception;
import com.tsr.simplechat.bean.messageentity;
import com.tsr.simplechat.receive_server.chatserver;
//客户端程序
public class chatclient extends frame {
private static final long serialversionuid = 1l;
// 聊天室id
private string groupid;
// 客户端用户名
private string clientname;
// 客户端消息发送服务套接字
private datagramsocket msg_send;
// 服务端口
private final int port = 10000;
// 服务器ip地址
private inetaddress ip;
// 客户端控件
textfield tf = new textfield(20);
textarea ta = new textarea();
button send = new button("send");
// 客户端构造器
public chatclient(string groupid, string clientname) {
super("聊天室:" + groupid + "/" + clientname);
this.clientname = clientname;
this.groupid = groupid;
// 设置客户端界面样式
add("north", tf);
add("center", ta);
add("south", send);
setsize(250, 250);
show();
// 聊天相关服务器初始化
init();
// 监视器
addwindowlistener(new windowadapter() {
public void windowclosing(windowevent e) {
// 关闭消息发送服务
msg_send.close();
// 关闭客户端程序
dispose();
system.exit(0);
}
});
}
// 聊天相关服务器初始化
private void init() {
// 注册当前用户及所在聊天室信息注册到服务器
chatserver.logingroup(groupid, this);
try {
// 初始化消息发送套接字对象
msg_send = new datagramsocket();
// 指定消息服务器
try {
ip = inetaddress.getbyname("127.0.0.1");
} catch (unknownhostexception e) {
system.out.println("未知的主机异常..");
}
} catch (socketexception e) {
system.out.println("套接字连接异常..");
}
}
// 消息发送按钮时间监听
public boolean action(event evt, object arg) {
if (evt.target.equals(send)) {
try {
// 获取输入内容
string content = tf.gettext();
// 发送消息
send_message(content);
// 清空聊天框
tf.settext(null);
} catch (exception ioe) {
system.out.print(ioe.getmessage());
}
}
return true;
}
// 消息发送
private void send_message(string content) {
// 消息格式化(json格式)
string message = messageformat(content);
// 将消息封装成udp数据包
byte[] buf = message.getbytes();
datagrampacket packet = new datagrampacket(buf, buf.length, ip, port);
try {
// 通过udp协议发送消息
msg_send.send(packet);
} catch (ioexception e) {
system.out.println("io异常..");
}
}
// 消息格式化
private string messageformat(string content) {
stringbuffer buffer = new stringbuffer();
buffer.append("{\"groupid\":").append("\"").append(groupid).append(
"\",");
buffer.append("\"username\":\"").append(clientname).append("\",");
buffer.append("\"text\":\"").append(content).append("\"}");
return buffer.tostring();
}
// 从服务器获取当前聊天室最新消息(回调..)
public void pushbackmessage(messageentity me) {
ta.append(me.getusername() + ":" + me.gettext());
ta.append("\n");
}
}
3、消息实体类
主要就是用于将消息封装成对象，包含：聊天室id、消息发送者昵称，消息内容。使用json格式解析。
package com.tsr.simplechat.bean;
//消息实体
public class messageentity {
private string groupid;
private string username;
private string text;
public string getgroupid() {
return groupid;
}
public void setgroupid(string groupid) {
this.groupid = groupid;
}
public string getusername() {
return username;
}
public void setusername(string username) {
this.username = username;
}
public string gettext() {
return text;
}
public void settext(string text) {
this.text = text;
}
}
4、ok，到了这里就基本搞定了，建立一个测试类。
•开启消息服务器。
•开启三个客户端，其中两个进入“聊天室001”，另一个进入“聊天室002”。
import com.tsr.simplechat.client.chatclient;
import com.tsr.simplechat.receive_server.chatserver;
public class test {
public static void main(string[] args) {
chatserver r = new chatserver();
r.start();
chatclient c1 = new chatclient("001", "小红");
chatclient c2 = new chatclient("001", "小绿");
chatclient c3 = new chatclient("002", "小黑");
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持萬仟网。
希望与广大网友互动？？
点此进行留言吧！
