123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428 |
- /*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
- package model;
-
- import gov.nist.javax.sip.DialogTimeoutEvent;
- import gov.nist.javax.sip.SipListenerExt;
- import gui.Hauptfenster;
- import java.net.InetAddress;
- import java.text.ParseException;
- import java.util.*;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- import javax.sdp.SdpException;
- import javax.sdp.SdpFactory;
- import javax.sdp.SessionDescription;
- import javax.sip.DialogTerminatedEvent;
- import javax.sip.IOExceptionEvent;
- import javax.sip.InvalidArgumentException;
- import javax.sip.ListeningPoint;
- import javax.sip.RequestEvent;
- import javax.sip.ResponseEvent;
- import javax.sip.SipException;
- import javax.sip.SipFactory;
- import javax.sip.SipProvider;
- import javax.sip.SipStack;
- import javax.sip.TimeoutEvent;
- import javax.sip.TransactionTerminatedEvent;
- import javax.sip.address.*;
- import javax.sip.header.*;
- import javax.sip.message.*;
- import logger.OhmLogger;
-
- /**
- *
- * @author Normal
- */
- public class VoIP implements SipListenerExt
- {
- Hauptfenster view; //später entfernen wegen Zugriff
- private static final Logger lg = OhmLogger.getLogger();
- SipFactory sipFactory; // Used to access the SIP API.
- SipStack sipStack; // The SIP stack.
- SipProvider sipProvider; // Used to send SIP messages.
- MessageFactory messageFactory; // Used to create SIP message factory.
- HeaderFactory headerFactory; // Used to create SIP headers.
- AddressFactory addressFactory; // Used to create SIP URIs.
- ListeningPoint listeningPoint; // SIP listening IP address/port.
- Properties properties; // Other properties.
-
- private int counter;
- private int myPort = 5060;
-
- private String myName = "129";
- private String protocolTyp = "UDP";
- private String myIPAddress;
- private String proxyAddress;
-
- Boolean invite;
-
- int tag = (new Random()).nextInt();
- private int branch = hashCode();
- Address contactAddress;
- private ContactHeader contactHeader;
-
- public VoIP(Hauptfenster view) //Konstruktor für eigene Daten
- {
- this.view = view;
- try
- {
- //wird an sich erstmal nicht gebraucht aber später sinnvoll um eigene Daten zu initialisieren
- String abc = InetAddress.getLocalHost().getHostAddress();
- invite = true;
- this.myIPAddress = InetAddress.getLocalHost().getHostAddress();
-
- this.sipFactory = SipFactory.getInstance();
- this.sipFactory.setPathName("gov.nist");
- this.properties = new Properties();
- this.properties.setProperty("javax.sip.STACK_NAME", "stack");
- this.sipStack = this.sipFactory.createSipStack(this.properties);
- this.messageFactory = this.sipFactory.createMessageFactory();
- this.headerFactory = this.sipFactory.createHeaderFactory();
- this.addressFactory = this.sipFactory.createAddressFactory();
- this.listeningPoint = this.sipStack.createListeningPoint(this.myIPAddress, this.myPort, this.protocolTyp);
- this.sipProvider = this.sipStack.createSipProvider(this.listeningPoint);
- this.sipProvider.addSipListener(this);
- this.contactAddress = this.addressFactory.createAddress("sip:129@" + this.myIPAddress + ":" + this.myPort); //+ ":" + this.myPort
- this.contactHeader = this.headerFactory.createContactHeader(contactAddress);
-
- //proxyAddress = "";
- }
- catch (Exception e)
- {
- System.out.println("Fehler bei Initialisierung eigener Addresse");
- System.exit(-1);
- }
-
- }
-
- public int hashCode()
- {
- int temp = tag * (new Random(100)).nextInt();
- return temp;
- }
-
- public void sendRegister(String serverIP, int serverPort) throws ParseException, InvalidArgumentException, SipException
- {
- lg.info("Vorbereiten des Registrierungs Headers");
- proxyAddress = serverIP + ":"+ serverPort;
- Address addressto = this.addressFactory.createAddress("sip:"+proxyAddress); //evtl. mit Port: sip:192.168.100.11:5060
- //Address addressto = this.addressFactory.createAddress("sip:192.168.100.11");
- ToHeader to = this.headerFactory.createToHeader(addressto, null); // Integer.toString(tag) address + tag
- URI requestURI = addressto.getURI();
- CallIdHeader callId = this.sipProvider.getNewCallId();
- FromHeader from = this.headerFactory.createFromHeader(addressto, String.valueOf(this.tag)); //this.contactAddress
- ArrayList via = new ArrayList(); //Via needs a List as input
- ViaHeader viaheader = this.headerFactory.createViaHeader(this.myIPAddress, this.myPort, "UDP", String.valueOf(branch));
- via.add(viaheader);
- CSeqHeader cSeq = this.headerFactory.createCSeqHeader(1L, "REGISTER");
- MaxForwardsHeader maxForwards = this.headerFactory.createMaxForwardsHeader(70);
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
- ExpiresHeader expire = this.headerFactory.createExpiresHeader(3600); //int value
- Request request = this.messageFactory.createRequest(requestURI, "REGISTER", callId, cSeq, from, to, via, maxForwards);
- request.addHeader(contactHeader);
- request.addHeader(allow);
- request.addHeader(expire);
- this.sipProvider.sendRequest(request);
- lg.info("Erfolgreiches Senden der Registrierung");
- }
-
- public void sendInvitation(String sipaddresse, String proxyaddresse, int serverPort) throws ParseException, InvalidArgumentException, SipException, SdpException
- {
- invite = true;
- Address addressto = this.addressFactory.createAddress("sip:"+sipaddresse+"@"+proxyaddresse); //evtl. mit Port: sip:192.168.100.11:5060
- //Address addressto = this.addressFactory.createAddress("sip:121@192.168.100.11");
- ToHeader to = this.headerFactory.createToHeader(addressto, null); // Integer.toString(tag) address + tag
- URI requestURI = addressto.getURI();
- CallIdHeader callId = this.sipProvider.getNewCallId();
- FromHeader from = this.headerFactory.createFromHeader(addressto, String.valueOf(this.tag)); //this.contactAddress
- ArrayList via = new ArrayList(); //Via needs a List as input
- ViaHeader viaheader = this.headerFactory.createViaHeader(this.myIPAddress, this.myPort, "UDP", String.valueOf(branch));
- via.add(viaheader);
- CSeqHeader cSeq = this.headerFactory.createCSeqHeader(1L, "INVITE");
- MaxForwardsHeader maxForwards = this.headerFactory.createMaxForwardsHeader(70);
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
- ExpiresHeader expire = this.headerFactory.createExpiresHeader(3600); //int value
- Request request = this.messageFactory.createRequest(requestURI, "INVITE", callId, cSeq, from, to, via, maxForwards);
- request.addHeader(contactHeader);
- request.addHeader(allow);
- request.addHeader(expire);
-
- ContentTypeHeader content = headerFactory.createContentTypeHeader("application", "sdp");
- request.addHeader(content);
-
- request.setContent(createSDPHeader(), content);
- System.out.println("---Invitation Header---");
- System.out.println(request);
- this.sipProvider.sendRequest(request);
- //lg.info("Erfolgreiches Senden der Invitation");
- }
-
- @Override
- public void processDialogTimeout(DialogTimeoutEvent timeoutEvent)
- {
- }
-
- @Override
- public void processRequest(RequestEvent requestEvent)
- {
- lg.info("Bekomme Anfrage");
- //Kommunikation mit Server das man zur Verfügung steht
- if ((Request.OPTIONS).equals(requestEvent.getRequest().getMethod())) //Options Anfrage von Server nach erfolgreicher Registrierung
- {
- lg.info("Option Request von Server, erstellen 200 OK zu Server");
- try
- {
- Response response = this.messageFactory.createResponse(200, requestEvent.getRequest());
- response.addHeader((ViaHeader) requestEvent.getRequest().getHeader("Via"));
- response.addHeader((FromHeader) requestEvent.getRequest().getHeader("From"));
- response.addHeader((ToHeader) requestEvent.getRequest().getHeader("To"));
- response.addHeader((CallIdHeader) requestEvent.getRequest().getHeader("Call-ID"));
- response.addHeader((CSeqHeader) requestEvent.getRequest().getHeader("Cseq"));
- //Kontakt Header
- response.addHeader(contactHeader);
- //Accept Header für application/sdp
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
- AllowEventsHeader allowevents = this.headerFactory.createAllowEventsHeader("talk,hold,refer,call-info");
- response.addHeader((CallIdHeader) requestEvent.getRequest().getHeader("Call-ID"));
- response.addHeader(allow);
- response.addHeader(allowevents);
- this.sipProvider.sendResponse(response);
- view.getTxtArea().append("Server Option Request erfolgreich beantwortet\n");
- lg.info("Erfolgreiches senden des Headers");
- }
- catch (ParseException | SipException ex)
- {
- lg.getLogger(VoIP.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- //Aktive Kommunikation
- else if ((Request.INVITE).equals(requestEvent.getRequest().getMethod())) // Invite von anderem Benutzer
- {
- FromHeader abc = (FromHeader) requestEvent.getRequest().getHeader("From");
- String name = abc.getName();
- view.getTxtArea().append("Werde von "+name+" angerufen\n");
- lg.info("Hab Invitation bekommen");
- try
- {
- //Trying Message to Server (Response Trying)
-
- Response responsetry = this.messageFactory.createResponse(100, requestEvent.getRequest());
- responsetry.addHeader((ViaHeader) requestEvent.getRequest().getHeader("Via"));
- responsetry.addHeader((FromHeader) requestEvent.getRequest().getHeader("From"));
- responsetry.addHeader((ToHeader) requestEvent.getRequest().getHeader("To"));
- responsetry.addHeader((CallIdHeader) requestEvent.getRequest().getHeader("Call-ID"));
- responsetry.addHeader((CSeqHeader) requestEvent.getRequest().getHeader("Cseq"));
-
- SupportedHeader supp = this.headerFactory.createSupportedHeader("replace,path,timer"); //nachschauen
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
-
- responsetry.addHeader(supp);
- responsetry.addHeader(allow);
- this.sipProvider.sendResponse(responsetry);
- view.getTxtArea().append("Trying geschickt\n");
- lg.info("Trying ist raus");
-
- //Ringing Message to Server (Responste Ringing)
- Response responsering = this.messageFactory.createResponse(180, requestEvent.getRequest());
- responsering.addHeader((ViaHeader) requestEvent.getRequest().getHeader("Via"));
- responsering.addHeader((FromHeader) requestEvent.getRequest().getHeader("From"));
-
- ToHeader temptoring = (ToHeader) requestEvent.getRequest().getHeader("To");
- String tempTag = String.valueOf(this.tag + Math.random());
- temptoring.setTag(tempTag); //evtl. besseren Tag
- responsering.addHeader(temptoring);
-
- responsering.addHeader((CSeqHeader) requestEvent.getRequest().getHeader("Cseq"));
- responsering.addHeader(contactHeader);
- responsering.addHeader(supp);
- responsering.addHeader(allow);
-
- AllowEventsHeader allowevent = this.headerFactory.createAllowEventsHeader("talk,hold");// für was gebraucht
- responsering.addHeader(allowevent);
- this.sipProvider.sendResponse(responsering);
- view.getTxtArea().append("Ringing geschickt\n");
-
- //Jetzt kommt 200 Ok SIP Header + SDP (SIP/SDP)
- //Sdp Header erstellen nächster Schritt
- invite = false;
- System.out.println(requestEvent.getDialog());
- Response okandSDP = this.messageFactory.createResponse(Response.OK, requestEvent.getRequest());
- //okandSDP.addHeader((ViaHeader) requestEvent.getRequest().getHeader("Via"));
- okandSDP.addHeader((FromHeader) requestEvent.getRequest().getHeader("From"));
-
- okandSDP.addHeader(temptoring); //evtl noch Ergänzungen
-
- okandSDP.addHeader((CSeqHeader) requestEvent.getRequest().getHeader("Cseq"));
- okandSDP.addHeader(contactHeader);
- okandSDP.addHeader(supp);
- okandSDP.addHeader(allow);
- okandSDP.addHeader(allowevent);
- ContentTypeHeader content = headerFactory.createContentTypeHeader("application", "sdp");
- okandSDP.addHeader(content);
- okandSDP.setContent(createSDPHeader(), content);
- System.out.println(okandSDP);
- this.sipProvider.sendResponse(okandSDP);
- }
- catch (ParseException | SipException | SdpException ex)
- {
- Logger.getLogger(VoIP.class.getName()).log(Level.SEVERE, null, ex);
-
- }
-
- }
- else if ((Request.ACK).equals(requestEvent.getRequest().getMethod()))
- {
-
- }
-
- }
-
- @Override
- public void processResponse(ResponseEvent responseEvent)
- {
- System.out.println("---Response---");
- //System.out.println(responseEvent.getResponse());
-
- if (responseEvent.getResponse().getStatusCode() == Response.UNAUTHORIZED)
- {
-
- try
- {
- Address addresstob = this.addressFactory.createAddress("sip:129@192.168.100.11"); //"sip:Jan@192.168.100.11"
- ToHeader temp = (ToHeader) responseEvent.getResponse().getHeader("To");
-
- ToHeader to = this.headerFactory.createToHeader(addresstob, temp.getTag()); // Integer.toString(tag) address + tag
- URI requestURI = addresstob.getURI();
-
- //CallIdHeader tempcall = (CallIdHeader)responseEvent.getResponse().getHeader("Call-ID");
- CallIdHeader callId = (CallIdHeader) responseEvent.getResponse().getHeader("Call-ID");
- FromHeader from = this.headerFactory.createFromHeader(addresstob, String.valueOf(this.tag)); //this.contactAddress
-
- //set Authorization header evtl. user Name benutzen den es gibt
- WWWAuthenticateHeader abc = (WWWAuthenticateHeader) responseEvent.getResponse().getHeader("WWW-Authenticate");
- AuthorizationHeader auth = this.headerFactory.createAuthorizationHeader("Digest");//was kommt in den string
-
- auth.setRealm(abc.getRealm());
- auth.setNonce(abc.getNonce());
- Address addresstest = this.addressFactory.createAddress("sip:" + myName + "@192.168.100.11"); //vielleicht passwort setzen "sip:"+myName+":\"\"@192.168.100.11"
- auth.setURI(addresstest.getURI());
- auth.setUsername(myName);
-
- ArrayList via = new ArrayList(); //Via needs a List as input
- ViaHeader viaheader = this.headerFactory.createViaHeader(this.myIPAddress, this.myPort, "UDP", String.valueOf(branch + 2));// String.valueOf(hashCode())string branch
- via.add(viaheader);
-
- CSeqHeader cSeq = this.headerFactory.createCSeqHeader(2L, "REGISTER");
- MaxForwardsHeader maxForwards = this.headerFactory.createMaxForwardsHeader(70);
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
- ExpiresHeader expire = this.headerFactory.createExpiresHeader(3600); //int value
-
- //Zusätzliche Register Header nach Unauthorzied
- //Create Request Header
- Request request = this.messageFactory.createRequest(requestURI, "REGISTER", callId, cSeq, from, to, via, maxForwards);
- request.addHeader(contactHeader);
- request.addHeader(allow);
- request.addHeader(expire);
- request.addHeader(auth);
- this.sipProvider.sendRequest(request);
- view.getTxtArea().append("Erfolgreich registriert\n");
- }
- catch (ParseException | SipException | InvalidArgumentException ex)
- {
- lg.getLogger(VoIP.class.getName()).log(Level.SEVERE, null, ex);
- }
-
- }
- else if (responseEvent.getResponse().getStatusCode() == Response.OK)
- {
- lg.info("Erfolgreichen Response (200 OK) bekommen");
- }
-
- }
-
- public SessionDescription createSDPHeader() throws SdpException
- {
- /*
- String contentparam = "v=0\r\n" + "o=129 1202 1202" + " IN IP4 192.168.100.247\r\n" + "s=SIP Call\r\n"
- + "c=192.168.100.247\r\n" + "t=0 0\r\n" + "m=audio 6022 RTP/AVP 0 4 18\r\n"
- + "a=rtpmap:0 PCMU/8000\r\n" + "a=rtpmap:4 G723/8000\r\n" + "a=rtpmap:18 G729A/8000\r\n" +
- "a=ptime:20\r\n";
- */
- SdpFactory sdpFactory = SdpFactory.getInstance();
- SessionDescription sessionDescription = sdpFactory.createSessionDescription();
- sessionDescription.setOrigin(sdpFactory.createOrigin(myName, 8000, 8000, "IN", "IP4", myIPAddress));
- sessionDescription.setSessionName(sdpFactory.createSessionName("SIP Call"));
- sessionDescription.setConnection(sdpFactory.createConnection("IN", "IP4", myIPAddress));
-
- //Media Body
- Vector mediavec = new Vector();
- if (invite = true)
- {
- String sdpformat[] =
- {
- "0", "4", "8", "18",
- };
- mediavec.add(sdpFactory.createMediaDescription("audio", 6022, 1, "RTP/AVP", sdpformat)); //(Übertragungstyp, Port, anzahl der Ports, Verbindungstyp,..)
- //Media Attribute
- mediavec.add(sdpFactory.createAttribute("sendrecv", null));
- mediavec.add(sdpFactory.createAttribute("rtpmap", "0 PCMU/8000"));
- mediavec.add(sdpFactory.createAttribute("rtpmap", "4 G723/8000"));
- mediavec.add(sdpFactory.createAttribute("rtpmap", "8 PCMA/8000"));
- mediavec.add(sdpFactory.createAttribute("rtpmap", "18 G729/8000"));
- mediavec.add(sdpFactory.createAttribute("ptime", "20"));
- }
- else
- {
-
- }
- sessionDescription.setAttributes(mediavec);
-
- return sessionDescription;
- }
-
- //Get Methoden falls man mal die Parameter braucht
- public void cancelcall()
- {
-
- }
- public String getmyName()
- {
- return myName;
- }
-
- public Integer getMyPort()
- {
- return myPort;
- }
-
- public String getMyIPAdress()
- {
- return myIPAddress;
- }
-
- @Override
- public void processTimeout(TimeoutEvent timeoutEvent)
- {
- }
-
- @Override
- public void processIOException(IOExceptionEvent exceptionEvent)
- {
- }
-
- @Override
- public void processTransactionTerminated(
- TransactionTerminatedEvent transactionTerminatedEvent)
- {
- }
-
- @Override
- public void processDialogTerminated(
- DialogTerminatedEvent dialogTerminatedEvent)
- {
- }
- }
|