import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public Request makeRequest(SipManager sipManager, long cseqNumber, int expiresTime) throws ParseException, InvalidArgumentException {

		AddressFactory addressFactory = sipManager.addressFactory;
		SipProvider sipProvider = sipManager.sipProvider;
		MessageFactory messageFactory = sipManager.messageFactory;
		HeaderFactory headerFactory = sipManager.headerFactory;
		// Create addresses and via header for the request
		Address fromAddress = addressFactory.createAddress("sip:"+ SipManager.sipUserName + "@"+ SipManager.registrarIp);
		fromAddress.setDisplayName(SipManager.sipUserName);
		Address toAddress = addressFactory.createAddress("sip:"	+ SipManager.sipUserName + "@"	+ SipManager.registrarIp);
		toAddress.setDisplayName(SipManager.sipUserName);
		Address contactAddress = sipManager.createContactAddress();
		ArrayList<ViaHeader> viaHeaders = sipManager.createViaHeader();
		URI requestURI = addressFactory.createAddress("sip:" + SipManager.registrarIp).getURI();
		// Build the request
		final Request request = messageFactory.createRequest(requestURI,
				Request.REGISTER, sipProvider.getNewCallId(),
				headerFactory.createCSeqHeader(cseqNumber, Request.REGISTER),
				headerFactory.createFromHeader(fromAddress, "c3ff411e"),
				headerFactory.createToHeader(toAddress, null), viaHeaders,
				headerFactory.createMaxForwardsHeader(70));
		// Add the contact header
		request.addHeader(headerFactory.createContactHeader(contactAddress));
		ExpiresHeader eh = headerFactory.createExpiresHeader(expiresTime);
		request.addHeader(eh);
		// Print the request
		System.out.println(request.toString());
		return request;
	}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public void processNotify(Request request,
        ServerTransaction serverTransactionId) {
    try {
        System.out.println("subsciber:  got a notify .");
        if (serverTransactionId == null) {
            System.out.println("subsciber:  null TID.");
            return;
        }
        Dialog dialog = serverTransactionId.getDialog();
        System.out.println("Dialog State = " + dialog.getState());
        Response response = messageFactory.createResponse(200, request);
        serverTransactionId.sendResponse(response);
        System.out.println("subsciber:  Sending OK.");
        System.out.println("Dialog State = " + dialog.getState());

        // Unsubscribe to the Subscription. Note that if you do not unsubscribe the dialog will
        // live on and eventually you will run out of memory.

        Request unsub = dialog.createRequest(Request.SUBSCRIBE);
        ExpiresHeader expiresHeader = headerFactory
                .createExpiresHeader(0);
        unsub.addHeader(expiresHeader);

        EventHeader eventHeader = null;
        eventHeader = headerFactory.createEventHeader("reg");
        unsub.addHeader(eventHeader);

        ClientTransaction ct = sipProvider.getNewClientTransaction(unsub);
        ct.sendRequest();

        dialog.delete();

    } catch (Exception ex) {
        ex.printStackTrace();
        System.exit(0);

    }
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public Request makeRequest(SipManager sipManager, long cseqNumber, int expiresTime) throws ParseException, InvalidArgumentException {

		AddressFactory addressFactory = sipManager.addressFactory;
		SipProvider sipProvider = sipManager.sipProvider;
		MessageFactory messageFactory = sipManager.messageFactory;
		HeaderFactory headerFactory = sipManager.headerFactory;
		
		// Create addresses and via header for the request
		Address fromAddress = addressFactory.createAddress("sip:"+ SipManager.sipUserName + "@"+ SipManager.registrarIp);
		fromAddress.setDisplayName(SipManager.sipUserName);
		Address toAddress = addressFactory.createAddress("sip:"	+ SipManager.sipUserName + "@"	+ SipManager.registrarIp);
		toAddress.setDisplayName(SipManager.sipUserName);
		Address contactAddress = sipManager.createContactAddress();
		ArrayList<ViaHeader> viaHeaders = sipManager.createViaHeader();
		URI requestURI = addressFactory.createAddress("sip:" + SipManager.registrarIp).getURI();
		
		// Build the request
		final Request request = messageFactory.createRequest(requestURI,
				Request.REGISTER, sipProvider.getNewCallId(),
				headerFactory.createCSeqHeader(cseqNumber, Request.REGISTER),
				headerFactory.createFromHeader(fromAddress, "c3ff411e"),
				headerFactory.createToHeader(toAddress, null), viaHeaders,
				headerFactory.createMaxForwardsHeader(70));
		
		// Add the contact header
		request.addHeader(headerFactory.createContactHeader(contactAddress));
		ExpiresHeader eh = headerFactory.createExpiresHeader(expiresTime);
		request.addHeader(eh);
		
		// Print the request
		System.out.println(request.toString());
		return request;
	}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
/**
     * Creates a default ACK SIPRequest message for this original request. Note that the
     * defaultACK SIPRequest does not include the content of the original SIPRequest. If
     * responseToHeader is null then the toHeader of this request is used to construct the ACK.
     * Note that tag fields are just copied from the original SIP Request. Added by Jeff Keyser.
     * 
     * @param responseToHeader To header to use for this request.
     * 
     * @return A SIPRequest with an ACK method.
     */
    public SIPRequest createAckRequest(To responseToHeader) {
//    	SIPRequest newRequest;
//        Iterator headerIterator;
//        SIPHeader nextHeader;

    	// cloning instead of iterating through headers so that lazy parsers don't have to parse the messages fully
    	// to create ACK requests
        SIPRequest newRequest = (SIPRequest) this.clone();
//        newRequest = new SIPRequest();
//        newRequest.setRequestLine((RequestLine) this.requestLine.clone());
        newRequest.setMethod(Request.ACK);
        // Ack and cancel do not get ROUTE headers.
        // Route header for ACK is assigned by the
        // Dialog if necessary.
        newRequest.removeHeader(RouteHeader.NAME);
        // Remove proxy auth header.
        // Assigned by the Dialog if necessary.
        newRequest.removeHeader(ProxyAuthorizationHeader.NAME);
        // Adding content is responsibility of user.
        newRequest.removeContent();
        // Content type header is removed since
        // content length is 0.
        newRequest.removeHeader(ContentTypeHeader.NAME);
        // The CSeq header field in the
        // ACK MUST contain the same value for the
        // sequence number as was present in the
        // original request, but the method parameter
        // MUST be equal to "ACK".
        try{
        	newRequest.getCSeq().setMethod(Request.ACK);
        } catch (ParseException e) {
        }
        if (responseToHeader != null) {
            newRequest.setTo(responseToHeader);
        }
        // CONTACT header does not apply for ACK requests.
        newRequest.removeHeader(ContactHeader.NAME);
        newRequest.removeHeader(ExpiresHeader.NAME);
        ViaList via = newRequest.getViaHeaders();
        // Bug reported by Gianluca Martinello
        // The ACK MUST contain a single Via header field,
        // and this MUST be equal to the top Via header
        // field of the original
        // request.
        if(via != null && via.size() > 1) {
        	for(int i = 2; i < via.size(); i++) {
        		via.remove(i);
        	}
        }
        
        if (MessageFactoryImpl.getDefaultUserAgentHeader() != null) {
            newRequest.setHeader(MessageFactoryImpl.getDefaultUserAgentHeader());

        }
        return newRequest;
    }
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void createFactoriesAndHeaders(Map<String, Object> parameters, SipComponent component) throws Exception {
    headerFactory = sipFactory.createHeaderFactory();
    addressFactory = sipFactory.createAddressFactory();
    setMessageFactory(sipFactory.createMessageFactory());
    
    fromHeader = component.resolveAndRemoveReferenceParameter(parameters, "fromHeader", FromHeader.class, null);
    if (fromHeader == null) { 
        createFromHeader();
    }
    if (!presenceAgent) {
        toHeader = component.resolveAndRemoveReferenceParameter(parameters, "toHeader", ToHeader.class, null);
        if (toHeader == null) {
            createToHeader();
        }
    }
    viaHeaders = component.resolveAndRemoveReferenceParameter(parameters, "viaHeaders", List.class, null);
    if (viaHeaders == null) {        
        createViaHeaders();
    }
    contentTypeHeader = component.resolveAndRemoveReferenceParameter(parameters, "contentTypeHeader", ContentTypeHeader.class, null);
    if (contentTypeHeader == null) {
        createContentTypeHeader();
    }

    callIdHeader = component.resolveAndRemoveReferenceParameter(parameters, "callIdHeader", CallIdHeader.class, null);
    
    maxForwardsHeader = component.resolveAndRemoveReferenceParameter(parameters, "maxForwardsHeader", MaxForwardsHeader.class, null);
    if (maxForwardsHeader == null) {        
        createMaxForwardsHeader();
    }
    
    // Optional Headers
    eventHeader = component.resolveAndRemoveReferenceParameter(parameters, "eventHeader", EventHeader.class, null);
    if (eventHeader == null) {
        createEventHeader();
    }        
    contactHeader = component.resolveAndRemoveReferenceParameter(parameters, "contactHeader", ContactHeader.class, null);
    if (contactHeader == null) {
        createContactHeader();
    }
    expiresHeader = component.resolveAndRemoveReferenceParameter(parameters, "expiresHeader", ExpiresHeader.class, null);
    if (expiresHeader == null) {
        createExpiresHeader();
    }
    extensionHeader = component.resolveAndRemoveReferenceParameter(parameters, "extensionHeader", ExtensionHeader.class, null);
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public ExpiresHeader getExpiresHeader() {
    return expiresHeader;
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
/**
 * A custom Header object containing message expiration details. Must implement the type javax.sip.header.ExpiresHeader
 */
public void setExpiresHeader(ExpiresHeader expiresHeader) {
    this.expiresHeader = expiresHeader;
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public ExpiresHeader getExpiresRegistration() {
	return expiresRegistration;
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public void setExpiresRegistration(ExpiresHeader expiresRegistration) {
	this.expiresRegistration = expiresRegistration;
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public ServerTransaction sendResponse(int status, Request request, ServerTransaction serverTransaction) {
        try {
            Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Starting response sending process.");
            
            if (serverTransaction == null)
                serverTransaction = udpSipProvider.getNewServerTransaction(request);
            
            Response response = messageFactory.createResponse(status, request);
            
            // Set "Exprires" header
            if (request.getHeader(ExpiresHeader.NAME) != null)
                response.setHeader(request.getHeader(ExpiresHeader.NAME));
            
            // Add "Contact" header
            Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Preparing \"Contact\" header...");
            try {
                SipURI contactURI = addressFactory.createSipURI(null, InetAddress.getLocalHost().getHostAddress());
                contactURI.setPort(sipPort);
            
                Address contactAddress      = addressFactory.createAddress(contactURI);
                
//				contactAddress.setDisplayName(mySipUsername);
                
                ContactHeader contactHeader = headerFactory.createContactHeader(contactAddress);
                response.addHeader(contactHeader);
            }
            catch (Exception e) {
                Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Exception occured when adding ContactHeader.", e);
//				return false;	// We can continue with this though.
            }
            
            Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Sending response:  " + response.toString());
            
            serverTransaction.sendResponse(response);
//			udpSipProvider.sendResponse(response);
            
            Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Response sent!");
            
            return serverTransaction;
        }
        catch (Exception ex) {
            Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  ", ex);
        }
        
        return null;
    }
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
public ServerTransaction sendResponse(int status, Request request, ServerTransaction serverTransaction) {
		try {
			Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Starting response sending process.");
			
			if (serverTransaction == null)
				serverTransaction = udpSipProvider.getNewServerTransaction(request);
			
			Response response = messageFactory.createResponse(status, request);
			
			// Set "Exprires" header
			if (request.getHeader(ExpiresHeader.NAME) != null)
				response.setHeader(request.getHeader(ExpiresHeader.NAME));
			
			// Add "Contact" header
			Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Preparing \"Contact\" header...");
			try {
				SipURI contactURI = addressFactory.createSipURI(null, InetAddress.getLocalHost().getHostAddress());
				contactURI.setPort(sipPort);
			
				Address contactAddress      = addressFactory.createAddress(contactURI);
				
//				contactAddress.setDisplayName(mySipUsername);
				
				ContactHeader contactHeader = headerFactory.createContactHeader(contactAddress);
				response.addHeader(contactHeader);
			}
			catch (Exception e) {
				Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Exception occured when adding ContactHeader.", e);
//				return false;	// We can continue with this though.
			}
			
			Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Sending response:  " + response.toString());
			
			serverTransaction.sendResponse(response);
//			udpSipProvider.sendResponse(response);
			
			Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  Response sent!");
			
			return serverTransaction;
		}
		catch (Exception ex) {
			Log.debug("SimpleSession(" + jid.getNode() + ").sendResponse:  ", ex);
		}
		
		return null;
	}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
SipSubscription(Request req)
{
	CallIdHeader ch = (CallIdHeader) req.getHeader("Call-ID");
	ToHeader th = (ToHeader) req.getHeader("To");
	FromHeader fh = (FromHeader) req.getHeader("From");
	rl = new LinkedList<Address>();

	this.callId = ch.getCallId();

	// incoming request from=remote

	ContactHeader cont = (ContactHeader) req.getHeader(ContactHeader.NAME);
	if (cont != null)
	{
		this.contact = cont.getAddress().getURI().toString();
	}

	// This is a server dialog. The top most record route
	// header is the one that is closest to us. We extract the
	// route list in the same order as the addresses in the
	// incoming request.

	if (rl.isEmpty())
	{
		ListIterator<?> rrl = req.getHeaders(RecordRouteHeader.NAME);
		while (rrl.hasNext())
		{
			RecordRouteHeader rrh = (RecordRouteHeader) rrl.next();
			rl.add(rrh.getAddress());
		}
	}

	remoteTag = fh.getTag();
	remoteParty = fh.getAddress();
	localTag = th.getTag();
	localParty = th.getAddress();

	if (localTag == null)
	{
		localTag = Integer.toString((int) (Math.random() * 100000));
	}

	ExpiresHeader eh = (ExpiresHeader) req.getHeader(ExpiresHeader.NAME);
	this.expires = System.currentTimeMillis() + (eh.getExpires() * 1000);

	cseq = 1;
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
void processOK(ClientTransaction clientTransatcion, Response response) {
    isRegistered = true;
    FromHeader fromHeader = ((FromHeader) response
            .getHeader(FromHeader.NAME));
    Address address = fromHeader.getAddress();

    int expires = 0;
    if (!isUnregistering) {
        ContactHeader contactHeader = (ContactHeader) response
                .getHeader(ContactHeader.NAME);
        // TODO check if the registrar created the contact address
        if (contactHeader != null) {
            expires = contactHeader.getExpires();
        } else {
            ExpiresHeader expiresHeader = response.getExpires();
            if (expiresHeader != null) {
                expires = expiresHeader.getExpires();
            }
        }
    }
    // expires may be null
    // fix by Luca Bincoletto <[email protected]>
    if (expires == 0) {
        isUnregistering = false;
        sipManCallback.fireUnregistered(address.toString());
    } else {
        if (reRegisterTimer != null)
            reRegisterTimer.cancel();
        if (keepAliveTimer != null)
            keepAliveTimer.cancel();

        reRegisterTimer = new Timer();
        keepAliveTimer = new Timer();
        // if (expires > 0 && expires < 60) {
        // [issue 2] Schedule re registrations
        // bug reported by [email protected]
        // use the value returned by the server to reschedule
        // registration
        SipURI uri = (SipURI) address.getURI();
        scheduleReRegistration(uri.getHost(), uri.getPort(), uri
                .getTransportParam(), expires);
        scheduleKeepAlive(SIPConfig.getKeepAliveDelay());
        // }
        /*
        * else{ SipURI uri = (SipURI) address.getURI();
        * scheduleReRegistration(uri.getHost(), uri.getPort(),
        * uri.getTransportParam(), expires); }
        */
        sipManCallback.fireRegistered(address.toString());

    }
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
/**
 * Get the exipres header.
 *
 * @return the expires header or null if one does not exist.
 */
public javax.sip.header.ExpiresHeader getExpires() {
    return (ExpiresHeader) getHeaderLowerCase(EXPIRES_LOWERCASE);
}
 

import javax.sip.header.ExpiresHeader; //导入依赖的package包/类
/**
 * Set the expiresHeader
 *
 * @param expiresHeader -- the expires header to set.
 */

public void setExpires(ExpiresHeader expiresHeader) {
    this.setHeader(expiresHeader);
}