org.jgroups.util.Util类的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(277)

本文整理了Java中org.jgroups.util.Util类的一些代码示例，展示了Util类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Util类的具体详情如下：
包路径：org.jgroups.util.Util
类名称：Util

Util介绍

[英]Collection of various utility routines that can not be assigned to other classes.
[中]无法分配给其他类的各种实用程序例程的集合。

代码示例

代码示例来源：origin: wildfly/wildfly

  1. public static void assertEquals(Object val1,Object val2) {
  2.   assertEquals(null,val1,val2);
  3. }

代码示例来源：origin: wildfly/wildfly

  1. public static void assertFalse(boolean condition) {
  2.   assertFalse(null,condition);
  3. }

代码示例来源：origin: wildfly/wildfly

  1. protected void applyNewConfig(byte[] buffer) {
  2.   final InputStream in=new ByteArrayInputStream(buffer);
  3.   Thread thread=new Thread(() -> {
  4.     try {
  5.       JChannel ch=new JChannel(in);
  6.       Util.sleepRandom(1000, 5000);
  7.       channel.disconnect();
  8.       JChannel tmp=channel;
  9.       channel=ch;
  10.       channel.setName(name);
  11.       channel.setReceiver(MPerf.this);
  12.       channel.connect("mperf");
  13.       local_addr=channel.getAddress();
  14.       JmxConfigurator.unregisterChannel(tmp, Util.getMBeanServer(), "jgroups", "mperf");
  15.       Util.close(tmp);
  16.       JmxConfigurator.registerChannel(channel, Util.getMBeanServer(), "jgroups", "mperf", true);
  17.     }
  18.     catch(Exception e) {
  19.       System.err.println("failed creating new channel");
  20.     }
  21.   });
  22.   System.out.println("<< restarting channel");
  23.   thread.start();
  24. }

代码示例来源：origin: wildfly/wildfly

  1. public void writeTo(DataOutput out) throws Exception {
  2.   out.writeByte(type);
  3.   Util.writeAddresses(mbrs, out);
  4.   Util.writeAddress(from, out);
  5. }

代码示例来源：origin: wildfly/wildfly

  1. public void readFrom(DataInput in) throws Exception {
  2.   type=in.readByte();
  3.   mbr=Util.readAddress(in);
  4.   sock_addr=Util.readStreamable(IpAddress::new, in);
  5.   int size=in.readInt();
  6.   if(size > 0) {
  7.     mbrs=new HashSet<>();
  8.     for(int i=0; i < size; i++)
  9.       mbrs.add(Util.readAddress(in));
  10.   }
  11. }

代码示例来源：origin: wildfly/wildfly

  1. private void loadProperties(File file) {
  2.   FileInputStream fis = null;
  3.   try {
  4.     fis = new FileInputStream(file);
  5.     properties.load(fis);
  6.   } catch (IOException e) {
  7.     log.error(Util.getMessage("AnErrorOccurredWhileLoadingPropertiesFrom") + file, e);
  8.   } finally {
  9.     Util.close(fis);
  10.   }
  11. }

代码示例来源：origin: wildfly/wildfly

  1. public void start() throws Exception {
  2.   try {
  3.     ch=new JChannel(props);
  4.     if(name != null)
  5.       ch.setName(name);
  6.     lock_service=new LockService(ch);
  7.     lock_service.addLockListener(this);
  8.     ch.connect("lock-cluster");
  9.     JmxConfigurator.registerChannel(ch, Util.getMBeanServer(), "lock-service", ch.getClusterName(), true);
  10.     loop();
  11.   }
  12.   catch(Exception e) {
  13.     e.printStackTrace();
  14.   }
  15.   finally {
  16.     Util.close(ch);
  17.   }
  18. }

代码示例来源：origin: wildfly/wildfly

  1. public void start(String props, String name) throws Exception {
  2.   ch=new JChannel(props);
  3.   ch.setName(name);
  4.   ch.setReceiver(this);
  5.   ch.connect("FlowControlTest");
  6.   loop();
  7.   Util.close(ch);
  8. }

代码示例来源：origin: wildfly/wildfly

  1. public void start(String props, boolean jmx, String name) throws Exception {
  2.   channel=new JChannel(props).name(name);
  3.   disp=new RpcDispatcher(channel, this) // no concurrent processing on incoming method calls
  4.    .setMembershipListener(this).setMethodLookup(id -> METHODS[0]);
  5.   if(jmx) {
  6.     MBeanServer srv=Util.getMBeanServer();
  7.     if(srv == null)
  8.       throw new Exception("No MBeanServers found");
  9.     JmxConfigurator.registerChannel(channel, srv, "jgroups", channel.getClusterName(), true);
  10.   }
  11.   channel.connect("rpc-speed-test");
  12.   View view=channel.getView();
  13.   if(view.size() > 2)
  14.     System.err.printf("More than 2 members in cluster: %s; terminating\n", view);
  15.   else
  16.     loop();
  17.   Util.close(disp, channel);
  18. }

代码示例来源：origin: wildfly/wildfly

  1. public static List<Message> readMessageList(DataInput in, short transport_id) throws Exception {
  2.   List<Message> list=new LinkedList<>();
  3.   Address dest=Util.readAddress(in);
  4.   Address src=Util.readAddress(in);
  5.   // AsciiString cluster_name=Bits.readAsciiString(in); // not used here
  6.   short length=in.readShort();
  7.   byte[] cluster_name=length >= 0? new byte[length] : null;
  8.   if(cluster_name != null)
  9.     in.readFully(cluster_name, 0, cluster_name.length);
  10.   int len=in.readInt();
  11.   for(int i=0; i < len; i++) {
  12.     Message msg=new Message(false);
  13.     msg.readFrom(in);
  14.     msg.setDest(dest);
  15.     if(msg.getSrc() == null)
  16.       msg.setSrc(src);
  17.     // Now add a TpHeader back on, was not marshalled. Every message references the *same* TpHeader, saving memory !
  18.     msg.putHeader(transport_id, new TpHeader(cluster_name));
  19.     list.add(msg);
  20.   }
  21.   return list;
  22. }

代码示例来源：origin: wildfly/wildfly

  1. protected void start(String props, String name) throws Exception {
  2.   channel=new JChannel(props).name(name);
  3.   // TP transport=channel.getProtocolStack().getTransport();
  4.   // transport.setThreadPool(new DirectExecutor());
  5.   disp=new RpcDispatcher(channel, this).setMembershipListener(this);
  6.   disp.setMethodLookup(ignored -> requestMethod);
  7.   channel.connect("rt");
  8.   View view=channel.getView();
  9.   if(view.size() > 2)
  10.     System.err.printf("More than 2 members found (%s); terminating\n", view);
  11.   else
  12.     loop();
  13.   Util.close(channel, disp);
  14. }

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. Address              sender=msg.getSrc();
  2. Message              assembled_msg;
  3. byte[]               m;
  4. m=frag_table.add(hdr.id, hdr.frag_id, hdr.num_frags, msg.getBuffer());
  5. if(m != null) {
  6.   try {
  7.     bis=new ByteArrayInputStream(m);
  8.     in=new DataInputStream(bis);
  9.     assembled_msg=new Message(false);
  10.     assembled_msg.readFrom(in);
  11.     if(log.isTraceEnabled()) log.trace("assembled_msg is " + assembled_msg);
  12.     assembled_msg.setSrc(sender); // needed ? YES, because fragments have a null src !!
  13.     num_received_msgs++;
  14.     up_prot.up(new Event(Event.MSG, assembled_msg));
  15.     Util.close(in);

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. FragHeader         hdr;
  2. Message            frag_msg;
  3. Address            dest=msg.getDest(), src=msg.getSrc();
  4. long               id=curr_id++; // used as seqnos
  5. int                num_frags;
  6.     bos.reset();
  7.     out=new DataOutputStream(bos);
  8.     msg.writeTo(out);
  9.     out.flush();
  10.     buffer=bos.getRawBuffer();
  11.     fragments=Util.fragmentBuffer(buffer, frag_size, bos.size());
  12.     hdr=new FragHeader(id, i, num_frags);
  13.     frag_msg.putHeader(name, hdr);
  14.     evt=new Event(Event.MSG, frag_msg);
  15.     down_prot.down(evt);
  16.   Util.close(out);

代码示例来源：origin: wildfly/wildfly

  1. Address dest=Util.readAddress(in);
  2. Address src=Util.readAddress(in);
  3. short length=in.readShort();
  4. byte[] cluster_name=length >= 0? new byte[length] : null;
  5.   Message msg=new Message(false);
  6.   msg.readFrom(in);
  7.   msg.setDest(dest);
  8.   if(msg.getSrc() == null)
  9.     msg.setSrc(src);

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. int     type=evt.getType();
  2. Message msg;
  3.   msg=(Message)evt.getArg();
  4.   if(!receive_local_msgs) {  // discard local messages (sent by myself to me)
  5.     if(local_addr != null && msg.getSrc() != null)
  6.       if(local_addr.equals(msg.getSrc()))
  7.         return null;
  8.   View tmp=(View)evt.getArg();
  9.   if(tmp instanceof MergeView)
  10.     my_view=new View(tmp.getVid(), tmp.getMembers());
  11.     log.warn("Channel has STREAMING_STATE_TRANSFER, however," +
  12.          " application does not implement ExtendedMessageListener. State is not transfered");
  13.     Util.close(is);        		     		        	
  14.   handleExit(evt);
  15.   return null;  // no need to pass event up; already done in handleExit()
  16.     log.warn("Channel has STREAMING_STATE_TRANSFER, however," +
  17.          " application does not implement ExtendedMessageListener. State is not transfered");        		
  18.     Util.close(os);

代码示例来源：origin: wildfly/wildfly

  1. public void start(JChannel ch) throws Exception {
  2.   this.ch=ch;
  3.   lock_service=new LockService(ch);
  4.   lock_service.addLockListener(this);
  5.   ch.connect("lock-cluster");
  6.   JmxConfigurator.registerChannel(ch, Util.getMBeanServer(), "lock-service", ch.getClusterName(), true);
  7.   try {
  8.     loop();
  9.   }
  10.   catch(Exception e) {
  11.     e.printStackTrace();
  12.   }
  13.   finally {
  14.     Util.close(ch);
  15.   }
  16. }

代码示例来源：origin: wildfly/wildfly

  1. protected void stop() {
  2.   log.info("%s: leaving bridge cluster '%s'", channel.getAddress(), channel.getClusterName());
  3.   Util.close(channel);
  4. }

代码示例来源：origin: wildfly/wildfly

  1. protected void setStateInApplication(InputStream in, Object resource, final Address provider) {
  2.   log.debug("%s: setting the state in the aplication", local_addr);
  3.   try {
  4.     up_prot.up(new Event(Event.STATE_TRANSFER_INPUTSTREAM, in));
  5.     up_prot.up(new Event(Event.STATE_TRANSFER_INPUTSTREAM_CLOSED, new StateTransferResult()));
  6.     down_prot.down(new Event(Event.GET_VIEW_FROM_COORD)); // https://issues.jboss.org/browse/JGRP-1751
  7.   }
  8.   catch(Throwable t) {
  9.     handleException(t);
  10.   }
  11.   finally {
  12.     Util.close(in);
  13.     close(resource);
  14.     if(isDigestNeeded()) {
  15.       openBarrierAndResumeStable();
  16.       closeHoleFor(provider);
  17.     }
  18.   }
  19. }

代码示例来源：origin: wildfly/wildfly

  1. /**
  2.  * Drops messages to/from other members and then closes the channel. Note that this member won't get excluded from
  3.  * the view until failure detection has kicked in and the new coord installed the new view
  4.  */
  5. public static void shutdown(JChannel ch) throws Exception {
  6.   DISCARD discard=new DISCARD();
  7.   discard.setLocalAddress(ch.getAddress());
  8.   discard.setDiscardAll(true);
  9.   ProtocolStack stack=ch.getProtocolStack();
  10.   TP transport=stack.getTransport();
  11.   stack.insertProtocol(discard,ProtocolStack.Position.ABOVE,transport.getClass());
  12.   //abruptly shutdown FD_SOCK just as in real life when member gets killed non gracefully
  13.   FD_SOCK fd=ch.getProtocolStack().findProtocol(FD_SOCK.class);
  14.   if(fd != null)
  15.     fd.stopServerSocket(false);
  16.   View view=ch.getView();
  17.   if(view != null) {
  18.     ViewId vid=view.getViewId();
  19.     List<Address> members=Collections.singletonList(ch.getAddress());
  20.     ViewId new_vid=new ViewId(ch.getAddress(),vid.getId() + 1);
  21.     View new_view=new View(new_vid,members);
  22.     // inject view in which the shut down member is the only element
  23.     GMS gms=stack.findProtocol(GMS.class);
  24.     gms.installView(new_view);
  25.   }
  26.   Util.close(ch);
  27. }

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. private List<Message> readMessageList(DataInputStream instream, Address dest, boolean multicast) throws Exception {
  2.   List<Message> list=new LinkedList<Message>();
  3.   int           len;
  4.   Message       msg;
  5.   Address       src;
  6.   len=instream.readInt();
  7.   src=Util.readAddress(instream);
  8.   for(int i=0; i < len; i++) {
  9.     msg=new Message(false); // don't create headers, readFrom() will do this
  10.     msg.readFrom(instream);
  11.     postUnmarshallingList(msg, dest, multicast);
  12.     msg.setSrc(src);
  13.     list.add(msg);
  14.   }
  15.   return list;
  16. }

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Util类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com