JGroups 채 팅 애플 릿 구현
효과 그림:
코드 부분:
package com.lei.jgoups;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.LinkedList;
import java.util.List;
import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.ReceiverAdapter;
import org.jgroups.View;
import org.jgroups.util.Util;
public class SimpleChat extends ReceiverAdapter{
JChannel channel;
String user_name=System.getProperty("user.name", "n/a");
final List<String> state=new LinkedList<String>();
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
private void start() throws Exception {
channel=new JChannel();// , udp.xml【YBXIANG:】 jgroups-x.y.z.Final.jar 。
channel.setReceiver(this);// Receiver
channel.connect("ChatCluster");
channel.getState(null, 10000);
eventLoop();
channel.close();
}
private void eventLoop() {
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
while(true) {
try {
System.out.print(">");
System.out.flush();
String line=in.readLine().toLowerCase();
if(line.startsWith("quit") || line.startsWith("exit"))
break;
line="[" + user_name + "] " + line;
Message msg=new Message(null, line);
channel.send(msg);
}
catch(Exception e) {
}
}
}
//
public void viewAccepted(View new_view) {
System.out.println("** view: " + new_view);
}
//
public void receive(Message msg) {
String line=msg.getSrc() + ": " + msg.getObject();
System.out.println(line);
synchronized(state) {//
state.add(line);
}
}
//getState
public void getState(OutputStream output) throws Exception {
synchronized(state) {
Util.objectToStream(state, new DataOutputStream(output));
}
}
// input stream , :
public void setState(InputStream input) throws Exception {
List<String> list;
list=(List<String>)Util.objectFromStream(new DataInputStream(input));
synchronized(state) {
state.clear();
state.addAll(list);
}
System.out.println(list.size() + " messages in chat history):");
for(String str: list) {
System.out.println(str);
}
}
}
가방:이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Prototype - 페이지 로 딩 후 js 파일 을 동적 으로 불 러 옵 니 다.prototype js 라 이브 러 리 를 사용 할 때 어떻게 실현 합 니까?너무 많 습 니 다. 한꺼번에 많이 불 러 오지 만 홈 페이지 에 사용 되 지 않 는 JS 라 이브 러 리 는 사용 자 를 바보 로 만 드...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.