yanf4j簡介，請(qǐng)看
這里。
這里俺要介紹下用yanf4j寫個(gè)最簡單的聊天室，可以直接telnet上去聊天。請(qǐng)先下載
common-logging和
yanf4j-0.40-stable-bin.tar.gz。
聊天室嘛，肯定要維護(hù)一個(gè)聊天者聊表：
List<Session> sessionList = new CopyOnWriteArrayList<Session>();
用戶名讓系統(tǒng)產(chǎn)生，用戶1、2、3.....，最簡單的嘛：
AtomicInteger userId = new AtomicInteger();
private String generateUserName() {
return "user" + userId.incrementAndGet();
}
服務(wù)端要實(shí)現(xiàn)一個(gè)處理handler，來接受用戶連接并轉(zhuǎn)發(fā)聊天消息，嗯，繼承HandlerAdapter，覆寫相應(yīng)的方法即可。當(dāng)有人連上來的時(shí)候，覆寫onSessionCreated方法：
public void onSessionCreated(Session session) {
sessionList.add(session);
// 給session取名
session.attach(generateUserName());
// 廣播某人進(jìn)來
broadcast(session, session.attachment() + " enter room");
}
當(dāng)收到聊天消息的時(shí)候，廣播給組內(nèi)成員：
@Override
public void onReceive(Session session, String t) {
if (t.equals("quit"))
session.close();
else
broadcast(session, "[" + session.attachment() + "] say:" + t);
}
private void broadcast(Session s, String msg) {
for (Session session : this.sessionList) {
session.send(msg);
}
}
廣播我們只是簡單的遍歷sessionList并send而已。完整的ChatServerHandler.java清單如下：
package com.google.code.yanf4j.test.example.chat;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicInteger;
import com.google.code.yanf4j.nio.Session;
import com.google.code.yanf4j.nio.impl.HandlerAdapter;
public class ChatServerHandler extends HandlerAdapter<String> {
List<Session> sessionList = new CopyOnWriteArrayList<Session>();
AtomicInteger userId = new AtomicInteger();
@Override
public void onReceive(Session session, String t) {
if (t.equals("quit"))
session.close();
else
broadcast(session, "[" + session.attachment() + "] say:" + t);
}
@Override
public void onSessionClosed(Session session) {
sessionList.remove(session);
broadcast(session, session.attachment() + " leave room");
}
private void broadcast(Session s, String msg) {
for (Session session : this.sessionList) {
session.send(msg);
}
}
@Override
public void onSessionCreated(Session session) {
sessionList.add(session);
// 給session取名
session.attach(generateUserName());
// 廣播某人進(jìn)來
broadcast(session, session.attachment() + " enter room");
}
private String generateUserName() {
return "user" + userId.incrementAndGet();
}
}
接下來我們要實(shí)現(xiàn)聊天服務(wù)器了，yanf4j實(shí)現(xiàn)TCP Server的核心類是TCPController，假設(shè)端口設(shè)為8080：
package com.google.code.yanf4j.test.example.chat;
import java.io.IOException;
import com.google.code.yanf4j.config.Configuration;
import com.google.code.yanf4j.nio.TCPController;
import com.google.code.yanf4j.nio.impl.StringCodecFactory;
public class ChatServer {
public static void main(String[] args) throws IOException {
TCPController controller = new TCPController(new Configuration(),
new StringCodecFactory());
controller.setHandler(new ChatServerHandler());
controller.setPort(8080); //端口
controller.start(); //啟動(dòng)
}
}
順利完成，啟動(dòng)后，telnet到8080端口，看看效果
