个人中心
gpt4 book ai didi

JGroups实现聊天小程序

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章JGroups实现聊天小程序由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

本文实例为大家分享了jgroups实现聊天小程序的具体代码，供大家参考，具体内容如下 。

效果图:

JGroups实现聊天小程序

代码部分:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
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);
  }
  }
}

架包:

JGroups实现聊天小程序

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：https://blog.csdn.net/junmoxi/article/details/78424426 。

最后此篇关于JGroups实现聊天小程序的文章就讲到这里了,如果你想了解更多关于JGroups实现聊天小程序的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： java网络通信技术之简单聊天小程序
文章推荐： java字符串常用操作方法(查找、截取、分割)
文章推荐： spring boot 监控处理方案实例详解
文章推荐： java聊天室的实现代码
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com