org.xbill.DNS.Message.getHeader()方法的使用及代码示例

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

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

Message.getHeader介绍

暂无

代码示例

代码示例来源：origin: julian-klode/dns66

  1. } else {
  2.   Log.i(TAG, "handleDnsRequest: DNS Name " + dnsQueryName + " Blocked!");
  3.   dnsMsg.getHeader().setFlag(Flags.QR);
  4.   dnsMsg.getHeader().setRcode(Rcode.NOERROR);
  5.   dnsMsg.addRecord(NEGATIVE_CACHE_SOA_RECORD, Section.AUTHORITY);
  6.   handleDnsResponse(parsedPacket, dnsMsg.toWire());

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

  1. public byte []
  2. errorMessage(Message query, int rcode) {
  3.   return buildErrorMessage(query.getHeader(), rcode,
  4.          query.getQuestion());
  5. }

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

  1. public Message
  2. newMessage() {
  3.   Message msg = new Message();
  4.   msg.getHeader().setOpcode(Opcode.UPDATE);
  5.   return msg;
  6. }

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-registry

  1. /**
  2.  * Generate an error message based on inbound query.
  3.  *
  4.  * @param query the query.
  5.  * @param rcode the response code for the specific error.
  6.  * @return the error message.
  7.  */
  8. public byte[] errorMessage(Message query, int rcode) {
  9.  return buildErrorMessage(query.getHeader(), rcode,
  10.    query.getQuestion());
  11. }

代码示例来源：origin: OpenNMS/opennms

  1. public byte[] errorMessage(final Message query, final int rcode) {
  2.     return buildErrorMessage(query.getHeader(), rcode, query.getQuestion());
  3.   }
  4. }

代码示例来源：origin: org.echocat.jomon.net/common

  1. public byte[] errorMessage(Message query, int rcode) {
  2.   return buildErrorMessage(query.getHeader(), rcode, query.getQuestion());
  3. }

代码示例来源：origin: org.jboss.resteasy/resteasy-eagledns-fork

  1. private byte[] errorMessage(Message query, int rcode) {
  2.   return buildErrorMessage(query.getHeader(), rcode, query.getQuestion());
  3. }

代码示例来源：origin: posicks/mdnsjava

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. protected void writeResponse(final Message message)
  5. throws IOException
  6. {
  7.   if (mdnsVerbose)
  8.   {
  9.     logger.logp(Level.INFO, getClass().getName(), "writeResponse", "Writing Response to " + multicastAddress.getHostAddress() + ":" + port);
  10.   }
  11.   
  12.   Header header = message.getHeader();
  13.   
  14.   header.setFlag(Flags.AA);
  15.   header.setFlag(Flags.QR);
  16.   header.setRcode(0);
  17.   
  18.   writeMessageToWire(message/* , true */);
  19. }

代码示例来源：origin: undera/jmeter-plugins

  1. protected byte[] getMessageBytes(String data) {
  2.   Message msg = new Message();
  3.   String recs[] = data.split(NL);
  4.   for (String rec : recs) {
  5.     if (rec.length() <= 3) {
  6.       Header head = msg.getHeader();
  7.       int val = Integer.parseInt(rec.trim());
  8.       if (val < 0) {
  9.         head.unsetFlag(-val);
  10.       } else {
  11.         head.setFlag(val);
  12.       }
  13.       msg.setHeader(head);
  14.     } else {
  15.       msg.addRecord(getRecord(rec.trim()), Section.QUESTION);
  16.     }
  17.   }
  18.   return msg.toWire();
  19. }

代码示例来源：origin: kg.apc/jmeter-plugins-extras-libs

  1. protected byte[] getMessageBytes(String data) {
  2.   Message msg = new Message();
  3.   String recs[] = data.split(NL);
  4.   for (String rec : recs) {
  5.     if (rec.length() <= 3) {
  6.       Header head = msg.getHeader();
  7.       int val = Integer.parseInt(rec.trim());
  8.       if (val < 0) {
  9.         head.unsetFlag(-val);
  10.       } else {
  11.         head.setFlag(val);
  12.       }
  13.       msg.setHeader(head);
  14.     } else {
  15.       msg.addRecord(getRecord(rec.trim()), Section.QUESTION);
  16.     }
  17.   }
  18.   return msg.toWire();
  19. }

代码示例来源：origin: posicks/mdnsjava

  1. public static Message newQueryResponse(final Record[] records, final int section)
  2. {
  3.   Message message = new Message();
  4.   Header header = message.getHeader();
  5.   
  6.   header.setRcode(Rcode.NOERROR);
  7.   header.setOpcode(Opcode.QUERY);
  8.   header.setFlag(Flags.QR);
  9.   
  10.   for (int index = 0; index < records.length; index++)
  11.   {
  12.     message.addRecord(records[index], section);
  13.   }
  14.   
  15.   return message;
  16. }

代码示例来源：origin: posicks/mdnsjava

  1. public void receiveMessage(Object id, Message message)
  2. {
  3.   if (message != null)
  4.   {
  5.     Header header = message.getHeader();
  6.     
  7.     if (header.getFlag(Flags.QR) || header.getFlag(Flags.AA))
  8.     {
  9.       if (matchesBrowse(message))
  10.       {
  11.         listenerProcessor.getDispatcher().receiveMessage(id, message);
  12.       }
  13.     }
  14.   }
  15. }

代码示例来源：origin: org.apache.james/apache-jspf

  1. private Message makeQuery(DNSRequest request, int id) throws TextParseException {
  2.     Name name = Name.fromString(request.getHostname(), Name.root);
  3.     
  4.     int type;
  5.     switch (request.getRecordType()) {
  6.       case DNSRequest.A: type = Type.A; break;
  7.       case DNSRequest.AAAA: type = Type.AAAA; break;
  8.       case DNSRequest.MX: type = Type.MX; break;
  9.       case DNSRequest.PTR: type = Type.PTR; break;
  10.       case DNSRequest.SPF: type = Type.SPF; break;
  11.       case DNSRequest.TXT: type = Type.TXT; break;
  12.       default: 
  13.         throw new UnsupportedOperationException("Unknown query type: "+request.getRecordType());
  14.     }
  15.     
  16.     Record question = Record.newRecord(name, type, DClass.ANY);
  17.     Message query = Message.newQuery(question);
  18.     query.getHeader().setID(id);
  19.     return query;
  20.   }
  21. }

代码示例来源：origin: org.apache.james.jspf/apache-jspf-resolver

  1. private Message makeQuery(DNSRequest request, int id) throws TextParseException {
  2.     Name name = Name.fromString(request.getHostname(), Name.root);
  3.     
  4.     int type;
  5.     switch (request.getRecordType()) {
  6.       case DNSRequest.A: type = Type.A; break;
  7.       case DNSRequest.AAAA: type = Type.AAAA; break;
  8.       case DNSRequest.MX: type = Type.MX; break;
  9.       case DNSRequest.PTR: type = Type.PTR; break;
  10.       case DNSRequest.SPF: type = Type.SPF; break;
  11.       case DNSRequest.TXT: type = Type.TXT; break;
  12.       default: 
  13.         throw new UnsupportedOperationException("Unknown query type: "+request.getRecordType());
  14.     }
  15.     
  16.     Record question = Record.newRecord(name, type, DClass.ANY);
  17.     Message query = Message.newQuery(question);
  18.     query.getHeader().setID(id);
  19.     return query;
  20.   }
  21. }

代码示例来源：origin: posicks/mdnsjava

  1. public void receiveMessage(final Object id, final Message m)
  2.   {
  3.     Header h = m.getHeader();
  4.     if (h.getFlag(Flags.QR) || h.getFlag(Flags.AA) || h.getFlag(Flags.AD))
  5.     {
  6.       if (MulticastDNSUtils.answersAny(query, m))
  7.       {
  8.         listener.receiveMessage(this.id, m);
  9.         unregisterListener(this);
  10.       }
  11.     } else
  12.     {
  13.       return;
  14.     }
  15.   }
  16. }

代码示例来源：origin: julian-klode/dns66

  1. assertEquals(NOERROR, responseMsg.getHeader().getRcode());
  2. assertArrayEquals(new Record[] {}, responseMsg.getSectionArray(Section.ANSWER));
  3. assertNotEquals(0, responseMsg.getSectionArray(Section.AUTHORITY).length);

代码示例来源：origin: posicks/mdnsjava

  1. protected Message convertUpdateToQueryResponse(final Message update)
  2. {
  3.   Message m = new Message();
  4.   Header h = m.getHeader();
  5.   
  6.   h.setOpcode(Opcode.QUERY);
  7.   h.setFlag(Flags.AA);
  8.   h.setFlag(Flags.QR);
  9.   
  10.   Record[] records = update.getSectionArray(Section.UPDATE);
  11.   for (int index = 0; index < records.length; index++ )
  12.   {
  13.     m.addRecord(records[index], Section.ANSWER);
  14.   }
  15.   
  16.   records = update.getSectionArray(Section.ADDITIONAL);
  17.   for (int index = 0; index < records.length; index++ )
  18.   {
  19.     m.addRecord(records[index], Section.ADDITIONAL);
  20.   }
  21.   
  22.   return m;
  23. }

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

  1. private void
  2. sendQuery() throws IOException {
  3.   Record question = Record.newRecord(zname, qtype, dclass);
  5.   Message query = new Message();
  6.   query.getHeader().setOpcode(Opcode.QUERY);
  7.   query.addRecord(question, Section.QUESTION);
  8.   if (qtype == Type.IXFR) {
  9.     Record soa = new SOARecord(zname, dclass, 0, Name.root,
  10.             Name.root, ixfr_serial,
  11.             0, 0, 0, 0);
  12.     query.addRecord(soa, Section.AUTHORITY);
  13.   }
  14.   if (tsig != null) {
  15.     tsig.apply(query, null);
  16.     verifier = new TSIG.StreamVerifier(tsig, query.getTSIG());
  17.   }
  18.   byte [] out = query.toWire(Message.MAXLENGTH);
  19.   client.send(out);
  20. }

代码示例来源：origin: tiandawu/IotXmpp

  1. private void
  2. sendQuery() throws IOException {
  3.   Record question = Record.newRecord(zname, qtype, dclass);
  5.   Message query = new Message();
  6.   query.getHeader().setOpcode(Opcode.QUERY);
  7.   query.addRecord(question, Section.QUESTION);
  8.   if (qtype == Type.IXFR) {
  9.     Record soa = new SOARecord(zname, dclass, 0, Name.root,
  10.             Name.root, ixfr_serial,
  11.             0, 0, 0, 0);
  12.     query.addRecord(soa, Section.AUTHORITY);
  13.   }
  14.   if (tsig != null) {
  15.     tsig.apply(query, null);
  16.     verifier = new TSIG.StreamVerifier(tsig, query.getTSIG());
  17.   }
  18.   byte [] out = query.toWire(Message.MAXLENGTH);
  19.   client.send(out);
  20. }

代码示例来源：origin: julian-klode/dns66

  1. assertEquals(NOERROR, responseMsg.getHeader().getRcode());
  2. assertArrayEquals(new Record[] {}, responseMsg.getSectionArray(Section.ANSWER));
  3. assertNotEquals(0, responseMsg.getSectionArray(Section.AUTHORITY).length);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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