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

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

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

Message.readFrom介绍

[英]Reads the message's contents from an input stream, but skips the buffer and instead returns the position (offset) at which the buffer starts
[中]从输入流读取消息内容，但跳过缓冲区，而是返回缓冲区开始的位置（偏移量）

代码示例

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

  1. protected static final Message readMessage(DataInput in) throws Exception {
  2.   short ver=in.readShort();
  3.   byte flags=in.readByte();
  4.   // final boolean multicast=(flags & (byte)2) == (byte)2;
  5.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  6.   msg.readFrom(in);
  7.   return msg;
  8. }

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

  1. public static Message readMessage(DataInput instream) throws Exception {
  2.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  3.   msg.readFrom(instream);
  4.   return msg;
  5. }

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

  1. public static Message byteBufferToMessage(byte[] buffer,int offset,int length) throws Exception {
  2.   DataInput in=new ByteArrayDataInputStream(buffer,offset,length);
  3.   if(!in.readBoolean())
  4.     return null;
  5.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  6.   msg.readFrom(in);
  7.   return msg;
  8. }

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

  1. public void run() {
  2.   // System.out.printf("[%s] reading from sock, conn: %s\n", Thread.currentThread().getName(), this);
  3.   try {
  4.     int len=in.readInt();
  5.     if(buffer == null || buffer.length < len)
  6.       buffer=new byte[len];
  7.     in.readFully(buffer, 0, len);
  8.     ByteArrayDataInputStream input=new ByteArrayDataInputStream(buffer, 0, len);
  9.     Message msg=new Message(false);
  10.     msg.readFrom(input);
  11.     thread_pool.execute(() -> up_prot.up(msg));
  12.   }
  13.   catch(IOException io_ex) {
  14.     runner.stop();
  15.     throw new RuntimeException(io_ex);
  16.   }
  17.   catch(Exception ex) {
  18.     if(sock.isClosed())
  19.       runner.stop();
  20.     throw new RuntimeException(ex);
  21.   }
  22. }

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

  1. protected static Message readMessage(byte[] buf, int offset, int length) throws Exception {
  2.   ByteArrayDataInputStream in=new ByteArrayDataInputStream(buf, offset, length);
  3.   short ver=in.readShort();
  4.   byte flags=in.readByte();
  5.   // final boolean multicast=(flags & (byte)2) == (byte)2;
  6.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  7.   msg.readFrom(in);
  8.   return msg;
  9. }

代码示例来源：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. public void run() {
  2.   final byte[]    receive_buf=new byte[65535];
  3.   DatagramPacket  packet=new DatagramPacket(receive_buf, receive_buf.length);
  4.   DataInput       inp;
  5.   while(sock != null && receiver != null && Thread.currentThread().equals(receiver)) {
  6.     packet.setData(receive_buf, 0, receive_buf.length);
  7.     try {
  8.       sock.receive(packet);
  9.       inp=new ByteArrayDataInputStream(packet.getData(), packet.getOffset(), packet.getLength());
  10.       Message msg=new Message();
  11.       msg.readFrom(inp);
  12.       up(msg);
  13.     }
  14.     catch(SocketException socketEx) {
  15.       break;
  16.     }
  17.     catch(Throwable ex) {
  18.       log.error(Util.getMessage("FailedReceivingPacketFrom"), packet.getSocketAddress(), ex);
  19.     }
  20.   }
  21.   if(log.isTraceEnabled())
  22.     log.trace("receiver thread terminated");
  23. }

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

  1. public void run() {
  2.   final byte[]   receive_buf=new byte[65535];
  3.   DatagramPacket packet=new DatagramPacket(receive_buf, receive_buf.length);
  4.   while(mcast_sock != null && receiver != null && Thread.currentThread().equals(receiver)) {
  5.     packet.setData(receive_buf, 0, receive_buf.length);
  6.     try {
  7.       mcast_sock.receive(packet);
  8.       DataInput inp=new ByteArrayDataInputStream(packet.getData(), packet.getOffset(), packet.getLength());
  9.       Message msg=new Message();
  10.       msg.readFrom(inp);
  11.       if(!Objects.equals(local_addr,msg.getSrc())) // discard discovery request from self
  12.         up(msg);
  13.     }
  14.     catch(SocketException socketEx) {
  15.       break;
  16.     }
  17.     catch(Throwable ex) {
  18.       log.error(Util.getMessage("FailedReceivingPacketFrom"), packet.getSocketAddress(), ex);
  19.     }
  20.   }
  21.   log.debug("receiver thread terminated");
  22. }

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

  1. protected void handleSingleMessage(DataInput in, boolean multicast) {
  2.   try {
  3.     Message msg=new Message(false); // don't create headers, readFrom() will do this
  4.     msg.readFrom(in);
  5.     if(!multicast && unicastDestMismatch(msg.getDest()))
  6.       return;
  7.     boolean oob=msg.isFlagSet(Message.Flag.OOB), internal=msg.isFlagSet(Message.Flag.INTERNAL);
  8.     msg_processing_policy.process(msg, oob, internal);
  9.   }
  10.   catch(Throwable t) {
  11.     log.error(String.format(Util.getMessage("IncomingMsgFailure"), local_addr), t);
  12.   }
  13. }

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

  1. for(int i=0; i < len; i++) {
  2.   Message msg=new Message(false);
  3.   msg.readFrom(in);
  4.   msg.setDest(dest);
  5.   if(msg.getSrc() == null)

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

  1. DataInput in=new ByteArrayDataInputStream(buf);
  2. Message assembled_msg=new Message(false);
  3. assembled_msg.readFrom(in);

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public static Message readMessage(DataInput instream) throws Exception {
  2.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  3.   msg.readFrom(instream);
  4.   return msg;
  5. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. protected static final Message readMessage(DataInput in) throws Exception {
  2.   short ver=in.readShort();
  3.   byte flags=in.readByte();
  4.   // final boolean multicast=(flags & (byte)2) == (byte)2;
  5.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  6.   msg.readFrom(in);
  7.   return msg;
  8. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public static Message byteBufferToMessage(byte[] buffer,int offset,int length) throws Exception {
  2.   DataInput in=new ByteArrayDataInputStream(buffer,offset,length);
  3.   if(!in.readBoolean())
  4.     return null;
  5.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  6.   msg.readFrom(in);
  7.   return msg;
  8. }

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

  1. private Message readMessage(DataInputStream instream, Address dest, Address sender, boolean multicast) throws Exception {
  2.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  3.   msg.readFrom(instream);
  4.   postUnmarshalling(msg, dest, sender, multicast); // allows for optimization by subclass
  5.   return msg;
  6. }

代码示例来源：origin: org.jgroups.kubernetes/common

  1. public void handlePingRequest(InputStream stream) throws Exception {
  2.   DataInputStream dataInput = new DataInputStream(stream);
  3.   Message msg = new Message();
  4.   msg.readFrom(dataInput);
  5.   try {
  6.     sendUp(msg);
  7.   } catch (Exception e) {
  8.     log.error("Error processing GET_MBRS_REQ.", e);
  9.   }
  10. }

代码示例来源：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. }

代码示例来源：origin: org.projectodd.openshift.ping/openshift-ping-common

  1. public void handlePingRequest(InputStream stream) throws Exception {
  2.   DataInputStream dataInput = new DataInputStream(stream);
  3.   Message msg = new Message();
  4.   msg.readFrom(dataInput);
  5.   try {
  6.     up(new Event(Event.MSG, msg));
  7.   } catch (Exception e) {
  8.     log.error("Error processing GET_MBRS_REQ.", e);
  9.   }
  10. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. protected static Message readMessage(byte[] buf, int offset, int length) throws Exception {
  2.   ByteArrayDataInputStream in=new ByteArrayDataInputStream(buf, offset, length);
  3.   short ver=in.readShort();
  4.   byte flags=in.readByte();
  5.   // final boolean multicast=(flags & (byte)2) == (byte)2;
  6.   Message msg=new Message(false); // don't create headers, readFrom() will do this
  7.   msg.readFrom(in);
  8.   return msg;
  9. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. protected void handleSingleMessage(DataInput in, boolean multicast) {
  2.   try {
  3.     Message msg=new Message(false); // don't create headers, readFrom() will do this
  4.     msg.readFrom(in);
  5.     if(!multicast && unicastDestMismatch(msg.getDest()))
  6.       return;
  7.     boolean oob=msg.isFlagSet(Message.Flag.OOB), internal=msg.isFlagSet(Message.Flag.INTERNAL);
  8.     msg_processing_policy.process(msg, oob, internal);
  9.   }
  10.   catch(Throwable t) {
  11.     log.error(String.format(Util.getMessage("IncomingMsgFailure"), local_addr), t);
  12.   }
  13. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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