本文實例為大家分享了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 state=new LinkedList();

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 list;

list=(List)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);

}

}

}

架包：

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

總結

以上是生活随笔為你收集整理的java中的jgroup_JGroups实现聊天小程序的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。