|  |  | 
 |  |  |  */ | 
 |  |  | package com.genersoft.iot.vmp.gb28181.auth; | 
 |  |  |  | 
 |  |  | import java.security.MessageDigest; | 
 |  |  | import java.security.NoSuchAlgorithmException; | 
 |  |  | import java.text.DecimalFormat; | 
 |  |  | import java.util.Date; | 
 |  |  | import java.util.Random; | 
 |  |  | import gov.nist.core.InternalErrorHandler; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  |  | 
 |  |  | import javax.sip.address.URI; | 
 |  |  | import javax.sip.header.AuthorizationHeader; | 
 |  |  | 
 |  |  | import javax.sip.header.WWWAuthenticateHeader; | 
 |  |  | import javax.sip.message.Request; | 
 |  |  | import javax.sip.message.Response; | 
 |  |  |  | 
 |  |  | import gov.nist.core.InternalErrorHandler; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | import java.security.MessageDigest; | 
 |  |  | import java.security.NoSuchAlgorithmException; | 
 |  |  | import java.time.Instant; | 
 |  |  | import java.util.Random; | 
 |  |  |  | 
 |  |  | /** | 
 |  |  |  * Implements the HTTP digest authentication method server side functionality. | 
 |  |  | 
 |  |  |      * @return a generated nonce. | 
 |  |  |      */ | 
 |  |  |     private String generateNonce() { | 
 |  |  |         // Get the time of day and run MD5 over it. | 
 |  |  |         Date date = new Date(); | 
 |  |  |         long time = date.getTime(); | 
 |  |  |         long time = Instant.now().toEpochMilli(); | 
 |  |  |         Random rand = new Random(); | 
 |  |  |         long pad = rand.nextLong(); | 
 |  |  |         // String nonceString = (new Long(time)).toString() | 
 |  |  |         //         + (new Long(pad)).toString(); | 
 |  |  |         String nonceString = Long.valueOf(time).toString() | 
 |  |  |                 + Long.valueOf(pad).toString(); | 
 |  |  |         byte mdbytes[] = messageDigest.digest(nonceString.getBytes()); | 
 |  |  |         // Convert the mdbytes array into a hex string. | 
 |  |  |         return toHexString(mdbytes); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |             WWWAuthenticateHeader proxyAuthenticate = headerFactory | 
 |  |  |                     .createWWWAuthenticateHeader(DEFAULT_SCHEME); | 
 |  |  |             proxyAuthenticate.setParameter("realm", realm); | 
 |  |  |             proxyAuthenticate.setParameter("qop", "auth"); | 
 |  |  |             proxyAuthenticate.setParameter("nonce", generateNonce()); | 
 |  |  |  | 
 |  |  |             proxyAuthenticate.setParameter("opaque", ""); | 
 |  |  |             proxyAuthenticate.setParameter("stale", "FALSE"); | 
 |  |  |             proxyAuthenticate.setParameter("algorithm", DEFAULT_ALGORITHM); | 
 |  |  |  | 
 |  |  | //            proxyAuthenticate.setParameter("qop", "auth"); | 
 |  |  |             response.setHeader(proxyAuthenticate); | 
 |  |  |         } catch (Exception ex) { | 
 |  |  |             InternalErrorHandler.handleException(ex); | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     public boolean doAuthenticateHashedPassword(Request request, String hashedPassword) { | 
 |  |  |         AuthorizationHeader authHeader = (AuthorizationHeader) request.getHeader(AuthorizationHeader.NAME); | 
 |  |  |         if ( authHeader == null ) return false; | 
 |  |  |         if ( authHeader == null ) { | 
 |  |  |             return false; | 
 |  |  |         } | 
 |  |  |         String realm = authHeader.getRealm(); | 
 |  |  |         String username = authHeader.getUsername(); | 
 |  |  |  | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     public boolean doAuthenticatePlainTextPassword(Request request, String pass) { | 
 |  |  |         AuthorizationHeader authHeader = (AuthorizationHeader) request.getHeader(AuthorizationHeader.NAME); | 
 |  |  |         if ( authHeader == null ) return false; | 
 |  |  |         if ( authHeader == null ) { | 
 |  |  |             return false; | 
 |  |  |         } | 
 |  |  |         String realm = authHeader.getRealm().trim(); | 
 |  |  |         String username = authHeader.getUsername().trim(); | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  |         // 客户端随机数,这是一个不透明的字符串值,由客户端提供,并且客户端和服务器都会使用,以避免用明文文本。 | 
 |  |  |         // 这使得双方都可以查验对方的身份,并对消息的完整性提供一些保护 | 
 |  |  |         //String cNonce = authHeader.getCNonce(); | 
 |  |  |         String cnonce = authHeader.getCNonce(); | 
 |  |  |  | 
 |  |  |         // nonce计数器,是一个16进制的数值,表示同一nonce下客户端发送出请求的数量 | 
 |  |  |         int nc = authHeader.getNonceCount(); | 
 |  |  |         String ncStr = new DecimalFormat("00000000").format(nc); | 
 |  |  | //        String ncStr = new DecimalFormat("00000000").format(Integer.parseInt(nc + "", 16)); | 
 |  |  |         String ncStr = String.format("%08x", nc).toUpperCase(); | 
 |  |  |         // String ncStr = new DecimalFormat("00000000").format(nc); | 
 |  |  |         // String ncStr = new DecimalFormat("00000000").format(Integer.parseInt(nc + "", 16)); | 
 |  |  |  | 
 |  |  |         String A1 = username + ":" + realm + ":" + pass; | 
 |  |  |  | 
 |  |  |         String A2 = request.getMethod().toUpperCase() + ":" + uri.toString(); | 
 |  |  |  | 
 |  |  |         byte mdbytes[] = messageDigest.digest(A1.getBytes()); | 
 |  |  |         String HA1 = toHexString(mdbytes); | 
 |  |  |         logger.debug("A1: " + A1); | 
 |  |  |         logger.debug("A2: " + A2); | 
 |  |  |  | 
 |  |  |         mdbytes = messageDigest.digest(A2.getBytes()); | 
 |  |  |         String HA2 = toHexString(mdbytes); | 
 |  |  |         logger.debug("HA1: " + HA1); | 
 |  |  |         logger.debug("HA2: " + HA2); | 
 |  |  |         String cnonce = authHeader.getCNonce(); | 
 |  |  |         // String cnonce = authHeader.getCNonce(); | 
 |  |  |         logger.debug("nonce: " + nonce); | 
 |  |  |         logger.debug("nc: " + ncStr); | 
 |  |  |         logger.debug("cnonce: " + cnonce); | 
 |  |  |         logger.debug("qop: " + qop); | 
 |  |  |         String KD = HA1 + ":" + nonce; | 
 |  |  |  | 
 |  |  |         if (qop != null && qop.equals("auth") ) { | 
 |  |  |         if (qop != null && qop.equalsIgnoreCase("auth") ) { | 
 |  |  |             if (nc != -1) { | 
 |  |  |                 KD += ":" + ncStr; | 
 |  |  |             } | 
 |  |  | 
 |  |  |         return mdString.equals(response); | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | } |