org.jgroups.Message.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.6k)|赞(0)|评价(0)|浏览(260)

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

Message.<init>介绍

[英]Constructs a message given a destination address
[中]在给定目标地址的情况下构造消息

代码示例

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

  1. public void run() {
  2.   Message heartbeat=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, new HeartbeatHeader());
  3.   down_prot.down(heartbeat);
  4.   num_heartbeats_sent++;
  5.   log.trace("Sent heartbeat");
  6. }

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

  1. protected void sendEof(Address requester) {
  2.   try {
  3.     Message eof_msg=new Message(requester).putHeader(getId(), new StateHeader(StateHeader.STATE_EOF));
  4.     log.trace("%s --> EOF --> %s", local_addr, requester);
  5.     down(eof_msg);
  6.   }
  7.   catch(Throwable t) {
  8.     log.error("%s: failed sending EOF to %s", local_addr, requester);
  9.   }
  10. }

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

  1. public void sendClose(Address dest, short conn_id) {
  2.   Message msg=new Message(dest).setFlag(Message.Flag.INTERNAL).putHeader(id, UnicastHeader3.createCloseHeader(conn_id));
  3.   log.trace("%s --> CLOSE(%s, conn-id=%d)", local_addr, dest, conn_id);
  4.   down_prot.down(msg);
  5. }

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

  1. public void run() {
  2.   Message heartbeat=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, new HeartbeatHeader());
  3.   down_prot.down(heartbeat);
  4.   num_heartbeats_sent++;
  5.   log.trace("Sent heartbeat");
  6. }

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

  1. protected void sendViewAck(Address dest) {
  2.   Message view_ack=new Message(dest).setFlag(OOB, INTERNAL)
  3.    .putHeader(this.id, new GmsHeader(GmsHeader.VIEW_ACK));
  4.   down_prot.down(view_ack);
  5. }

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

  1. protected void sendHeartbeatResponse(Address dest) {
  2.   Message hb_ack=new Message(dest).setFlag(Message.Flag.INTERNAL);
  3.   FdHeader tmp_hdr=new FdHeader(FdHeader.HEARTBEAT_ACK);
  4.   tmp_hdr.from=local_addr;
  5.   hb_ack.putHeader(this.id, tmp_hdr);
  6.   down_prot.down(hb_ack);
  7. }

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

  1. protected synchronized boolean handleMessage(Address sender, byte msg_bit) {
  2.   boolean retval=false;
  3.   if(this.bit == msg_bit) {
  4.     this.bit^=1;
  5.     retval=true;
  6.   }
  7.   byte ack_bit=(byte)(this.bit ^ 1);
  8.   Message ack=new Message(sender).putHeader(id, new ABPHeader(Type.ack, ack_bit));
  9.   log.trace("%s: --> %s.ack(%d)", local_addr, sender, ack_bit);
  10.   down_prot.down(ack);
  11.   return retval;
  12. }

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

  1. protected void sendRequestForFirstSeqno(Address dest) {
  2.   if(last_sync_sent.addIfAbsentOrExpired(dest)) {
  3.     Message msg=new Message(dest).setFlag(Message.Flag.OOB)
  4.      .putHeader(this.id, UnicastHeader3.createSendFirstSeqnoHeader(timestamper.incrementAndGet()));
  5.     log.trace("%s --> SEND_FIRST_SEQNO(%s)", local_addr, dest);
  6.     down_prot.down(msg);
  7.   }
  8. }

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

  1. protected void sendLockInfoRequestTo(Buffer buf, Address[] mbrs, Address exclude) {
  2.   Stream.of(mbrs).filter(m -> m != null && !Objects.equals(m, exclude)).forEach(dest -> {
  3.     Message msg=new Message(dest, buf).putHeader(id, new LockingHeader());
  4.     if(bypass_bundling)
  5.       msg.setFlag(Message.Flag.DONT_BUNDLE);
  6.     try {
  7.       down_prot.down(msg);
  8.     }
  9.     catch(Throwable t) {
  10.       log.error("%s: failed sending LOCK_INFO_REQ to %s: %s", local_addr, dest, t);
  11.     }
  12.   });
  13. }

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

  1. protected void sendJoinResponse(Buffer marshalled_rsp, Address dest) {
  2.   Message m=new Message(dest, marshalled_rsp).putHeader(this.id, new GmsHeader(GmsHeader.JOIN_RSP))
  3.    .setFlag(OOB, INTERNAL);
  4.   getDownProtocol().down(m);
  5. }

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

  1. public void run() {
  2.   FD.FdHeader hdr;
  3.   synchronized(suspected_members) {
  4.     if(suspected_members.isEmpty()) {
  5.       stop();
  6.       return;
  7.     }
  8.     hdr=new FdHeader(FdHeader.SUSPECT);
  9.     hdr.mbrs=new ArrayList<>(suspected_members);
  10.     hdr.from=local_addr;
  11.   }
  12.   Message suspect_msg=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, hdr);
  13.   log.trace("%s: broadcasting SUSPECT message (suspects=%s)", local_addr, suspected_members);
  14.   down_prot.down(suspect_msg);
  15. }

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

  1. /**
  2.  Sends or broadcasts a I_HAVE_SOCK response. If 'dst' is null, the reponse will be broadcast, otherwise
  3.  it will be unicast back to the requester
  4.  */
  5. protected void sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr) {
  6.   Message msg=new Message(dst).setFlag(Message.Flag.INTERNAL).setTransientFlag(Message.TransientFlag.DONT_LOOPBACK);
  7.   FdHeader hdr=new FdHeader(FdHeader.I_HAVE_SOCK, mbr);
  8.   hdr.sock_addr=addr;
  9.   msg.putHeader(this.id, hdr);
  10.   down_prot.down(msg);
  11. }

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

  1. protected void sendSeqnoResponse(Address original_sender,long seqno, int num_seqnos) {
  2.   SequencerHeader hdr = new SequencerHeader(SequencerHeader.RESPONSE, seqno, num_seqnos);
  3.   Message ucast_msg = new Message(original_sender).putHeader(this.id, hdr);
  4.   
  5.   if (log.isTraceEnabled())
  6.     log.trace(local_addr + ": sending seqno response to " + original_sender + ":: new_seqno=" + seqno + ", num_seqnos=" + num_seqnos);
  7.   down_prot.down(ucast_msg);
  8.   sent_responses++;
  9. }

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

  1. public void run() {
  2.   log.trace("%s: broadcasting SUSPECT message (suspected_mbrs=%s)", local_addr, suspects);
  3.   FdHeader hdr;
  4.   synchronized(suspects) {
  5.     if(suspects.isEmpty()) {
  6.       stopTask();
  7.       return;
  8.     }
  9.     hdr=new FdHeader(FdHeader.SUSPECT).mbrs(new HashSet<>(suspects));
  10.   }
  11.   Message suspect_msg=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, hdr); // mcast SUSPECT to all members
  12.   down_prot.down(suspect_msg);
  13. }

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

  1. protected void sendCredit(Address dest, long credits) {
  2.   if(log.isTraceEnabled())
  3.     log.trace("sending %d credits to %s", credits, dest);
  4.   Message msg=new Message(dest, longToBuffer(credits))
  5.    .setFlag(Message.Flag.OOB, Message.Flag.INTERNAL, Message.Flag.DONT_BUNDLE)
  6.    .putHeader(this.id,getReplenishHeader());
  7.   down_prot.down(msg);
  8.   num_credit_responses_sent++;
  9. }

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

  1. private void sendLeaveResponses(Collection<Address> leaving_members) {
  2.   for(Address address: leaving_members){
  3.     Message msg=new Message(address).setFlag(Message.Flag.OOB, Message.Flag.INTERNAL, Message.Flag.NO_RELIABILITY)
  4.      .putHeader(gms.getId(), new GMS.GmsHeader(GMS.GmsHeader.LEAVE_RSP));
  5.     log.trace("%s: sending LEAVE response to %s", gms.local_addr, address);
  6.     gms.getDownProtocol().down(msg);
  7.   }
  8. }

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

  1. protected void send(Address dest, Request req) {
  2.   Message msg=new Message(dest, Util.streamableToBuffer(req)).putHeader(id, new LockingHeader());
  3.   if(bypass_bundling)
  4.     msg.setFlag(Message.Flag.DONT_BUNDLE);
  5.   log.trace("%s --> %s: %s", local_addr, dest == null? "ALL" : dest, req);
  6.   try {
  7.     down_prot.down(msg);
  8.   }
  9.   catch(Exception ex) {
  10.     log.error("%s: failed sending %s request: %s", local_addr, req.type, ex);
  11.   }
  12. }

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

  1. protected void broadcastUnuspectMessage(Address mbr) {
  2.   if(mbr == null) return;
  3.   log.debug("%s: broadcasting unsuspect(%s)", local_addr, mbr);
  4.   // 1. Send a SUSPECT message right away; the broadcast task will take some time to send it (sleeps first)
  5.   FdHeader hdr=new FdHeader(FdHeader.UNSUSPECT).mbrs(Collections.singleton(mbr));
  6.   Message suspect_msg=new Message().setFlag(Message.Flag.INTERNAL).putHeader(this.id, hdr);
  7.   down_prot.down(suspect_msg);
  8. }

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

  1. protected void sendAck(Address dst, long seqno, short conn_id) {
  2.   if(!running) // if we are disconnected, then don't send any acks which throw exceptions on shutdown
  3.     return;
  4.   Message ack=new Message(dst).setFlag(Message.Flag.INTERNAL).
  5.    putHeader(this.id, UnicastHeader3.createAckHeader(seqno, conn_id, timestamper.incrementAndGet()));
  6.   if(is_trace)
  7.     log.trace("%s --> ACK(%s: #%d)", local_addr, dst, seqno);
  8.   try {
  9.     down_prot.down(ack);
  10.     num_acks_sent++;
  11.   }
  12.   catch(Throwable t) {
  13.     log.error(Util.getMessage("FailedSendingAck"), local_addr, seqno, dst, t);
  14.   }
  15. }

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

  1. protected void send(Address dest, Buffer buffer) {
  2.   try {
  3.     Message rsp_msg=new Message(dest, buffer).putHeader(id, new CounterHeader());
  4.     if(bypass_bundling)
  5.       rsp_msg.setFlag(Message.Flag.DONT_BUNDLE);
  6.     down_prot.down(rsp_msg);
  7.   }
  8.   catch(Exception ex) {
  9.     log.error(Util.getMessage("FailedSendingMessageTo") + dest + ": " + ex);
  10.   }
  11. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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