# User Authentication
**URL:** https://community.wowza.com/t/user-authentication/113
**Category:** Wowza Streaming Engine
**Created:** [May 6, 2007, 11:35pm UTC](https://community.wowza.com/t/user-authentication/113 "2007-05-06T23:35:08Z")
**Posts on this page:** 20
**Page:** 1
### Author:  [@system](https://community.wowza.com/u/system)
#### Post date: [May 6, 2007, 11:35pm UTC](https://community.wowza.com/t/user-authentication/113/1 "2007-05-06T23:35:08Z")
Hi,
I would like to restrict access to files on the server to registered users and need some kind of login module. I have the users details in a mysql database on a seperate server but I am not sure how to go about accessing the database from wowza. any help would be appreciated.
Thanks.
Roger.
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [May 7, 2007, 3:52am UTC](https://community.wowza.com/t/user-authentication/113/2 "2007-05-07T03:52:26Z")
I downloaded the JDBC driver from mysql from here:
[http://dev.mysql.com/downloads/connector/j/5.0.html](http://dev.mysql.com/downloads/connector/j/5.0.html)
Unzip and driver archive and drop the driver **mysql-connector-java-5.0.5-bin.jar** into the Wowza Pro lib folder **[install-dir]/lib**.
The serverside Java code would look something like this:
```auto
package com.mycompany.wms.dbtest;
import java.sql.*;
import com.wowza.wms.application.*;
import com.wowza.wms.amf.*;
import com.wowza.wms.client.*;
import com.wowza.wms.module.*;
import com.wowza.wms.request.*;
public class DBTest extends ModuleBase
{
static public void onConnect(IClient client, RequestFunction function,
AMFDataList params)
{
String userName = getParamString(params, PARAM1);
String password = getParamString(params, PARAM2);
// preload the driver class
try
{
Class.forName("com.mysql.jdbc.Driver").newInstance();
}
catch (Exception e)
{
getLogger().error("Error loading: com.mysql.jdbc.Driver: "+e.toString());
}
Connection conn = null;
try
{
conn = DriverManager.getConnection("jdbc:mysql://localhost/test?user=monty&password=greatsqldb");
Statement stmt = null;
ResultSet rs = null;
try
{
stmt = conn.createStatement();
rs = stmt.executeQuery("SELECT count(*) as userCount FROM users where username = '"+userName+"' and password = '"+password+"'");
if (rs.next() == true)
{
if (rs.getInt("userCount") > 0)
{
client.acceptConnection();
}
}
}
catch (SQLException sqlEx)
{
getLogger().error("sqlexecuteException: " + sqlEx.toString());
}
finally
{
// it is a good idea to release
// resources in a finally{} block
// in reverse-order of their creation
// if they are no-longer needed
if (rs != null)
{
try
{
rs.close();
}
catch (SQLException sqlEx)
{
rs = null;
}
}
if (stmt != null)
{
try
{
stmt.close();
}
catch (SQLException sqlEx)
{
stmt = null;
}
}
}
conn.close();
}
catch (SQLException ex)
{
// handle any errors
System.out.println("SQLException: " + ex.getMessage());
System.out.println("SQLState: " + ex.getSQLState());
System.out.println("VendorError: " + ex.getErrorCode());
}
getLogger().info("onConnect: " + client.getClientId());
}
static public void onConnectAccept(IClient client)
{
getLogger().info("onConnectAccept: " + client.getClientId());
}
static public void onConnectReject(IClient client)
{
getLogger().info("onConnectReject: " + client.getClientId());
}
static public void onDisconnect(IClient client)
{
getLogger().info("onDisconnect: " + client.getClientId());
}
}
```
Then edit your Application.xml and add a reference to this new module to the section and set **Connections/AutoAccept** to **false**.
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [September 4, 2008, 6:16am UTC](https://community.wowza.com/t/user-authentication/113/3 "2008-09-04T06:16:40Z")
Also, add a bunch of log statements to your code so you can see what is happening. It is the best way to figure it out.
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [May 21, 2007, 9:16am UTC](https://community.wowza.com/t/user-authentication/113/4 "2007-05-21T09:16:44Z")
This example just passess the user credentials through the NetConnection.connect call. So in this example the connect call would look like:
```auto
var nc:NetConnection = new NetConnection();
nc.connect(url, userName, password);
```
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [June 5, 2007, 2:57am UTC](https://community.wowza.com/t/user-authentication/113/5 "2007-06-05T02:57:25Z")
Are you passing the username and password as part of the connect command?
Client side code:
```auto
var nc:NetConnection = new NetConnection();
var userName:String = "charlie";
var password:String = "mypassword";
nc.connect("rtmp://localhost/myapplication", userName, password);
```
The java.lang.reflect.InvocationTargetException just means that there was an error somewhere in the onConnect method that was not caught by a try/catch block. The only part of this code that is not surrounded in a try/catch blocks is the place where it resolves the userName and password from the connect command.
One other thing you can try is to surround all the code in the method with the try/catch block that looks like this:
```auto
static public void onConnect(IClient client, RequestFunction function, AMFDataList params)
{
try
{
//put all the code of the method here
}
catch (Exception e)
{
System.out.println("ERROR: "+e.toString());
e.printStackTrace();
}
}
```
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [June 7, 2007, 12:56am UTC](https://community.wowza.com/t/user-authentication/113/6 "2007-06-07T00:56:21Z")
I am pretty sure that client.rejectConnection(String); is not being called. Can you try a simple onConnect handler just to verify:
```auto
static public void onConnect(IClient client, RequestFunction function, AMFDataList params)
{
client.rejectConnection("Testing");
}
```
I think you will find that its working.
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [June 8, 2007, 12:54am UTC](https://community.wowza.com/t/user-authentication/113/7 "2007-06-08T00:54:16Z")
I just tried it myself and it works great. I did the following.
Created this server side module:
```auto
package com.wowza.wms.plugin.test.module;
import com.wowza.wms.amf.*;
import com.wowza.wms.client.*;
import com.wowza.wms.module.*;
import com.wowza.wms.request.*;
import com.wowza.wms.stream.*;
import com.wowza.wms.application.*;
import com.wowza.wms.sharedobject.*;
public class ModuleInternalTest extends ModuleBase
{
public static void onConnect(IClient client, RequestFunction function, AMFDataList params)
{
getLogger().info("REJECT");
client.rejectConnection();
}
}
```
Added this bit of XML to end of the list of my conf/Application.xml file:
```auto
test
test
com.wowza.wms.plugin.test.module.ModuleInternalTest
```
Connected to the server and the connection was rejected. Are you sure your code is being called? Did you add the entry to the proper Application.xml file? Do you add your entry at the end of the list?
If you still can’t get it to work, send me your Java files and zip up and send me your conf folder.
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [June 8, 2007, 7:05am UTC](https://community.wowza.com/t/user-authentication/113/8 "2007-06-08T07:05:50Z")
I think the problem is the log entry that is generating:
```auto
INFO server comment - onConnect: false
```
Try edit the Application.xml file for this application and make sure the only modules defined for this application are:
```auto
base
Base
com.wowza.wms.module.ModuleCore
properties
Properties
com.wowza.wms.module.ModuleProperties
logging
Client Logging
com.wowza.wms.module.ModuleClientLogging
test
test
com.wowza.wms.plugin.test.module.ModuleInternalTest
```
The way the module stuff works is that it will call the event handlers in the order in which the modules are defined in the Application.xml. So maybe there is another module that is calling acceptConnection after the rejectConnection.
I realize that I keep hammering you with the same answer that it works. I am pretty confident that it works. I apologize. I am not sure what else to do. I do believe it is something on your end. So do send me your [install-dir]/conf folder zipped up along with your Java code so I can take a look. Send it to charlie@wowza.com.
Charlie
---
### Author:  [@Charlie\_Good](https://community.wowza.com/u/Charlie_Good)
#### Post date: [September 2, 2008, 4:18am UTC](https://community.wowza.com/t/user-authentication/113/9 "2008-09-02T04:18:01Z")
Looks like you do not have all the required libraries (.jar files) copied into the Wowza Pro [intsall-dir]/lib folder. The class that is missing is org/aspectj/lang/Signature.
Charlie
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 4, 2008, 11:43am UTC](https://community.wowza.com/t/user-authentication/113/10 "2008-09-04T11:43:42Z")
Hi there,
Assuming that you are using code similar to charlie’s post on page 1 of this thread, add some System.out.println statements to see what is happening.
```auto
Statement stmt = null;
ResultSet rs = null;
try
{
stmt = conn.createStatement();
String sql = "SELECT count(*) as userCount FROM users where username = '"+userName+"' and password = '"+password+"'";
System.out.println("sql: "+sql);
rs = stmt.executeQuery(sql);
if (rs.next() == true)
{
System.out.println("rs.getInt("userCount"): "+rs.getInt("userCount") );
if (rs.getInt("userCount") > 0)
{
System.out.println("client.acceptConnection()");
client.acceptConnection();
}
}
else
{
System.out.println("Error - userCount = 0. Rejecting connection");
}
}
```
I have added the sql statement as a seperate string so it can be checked for syntax.
You can also copy and paste the sql into phpmyadmin or another sql client and check it is working as expected.
Try this a see what happens.
Roger.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 8:30am UTC](https://community.wowza.com/t/user-authentication/113/11 "2008-09-05T08:30:51Z")
Hi,
The debug error is happening after the reject so I dont think it is the problem.
Can you post an example of your java code for onConnect, onConnectReject & onConnectAccept.
I have checked out the flash code and it seems to be working ok.
Roger.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 9:44am UTC](https://community.wowza.com/t/user-authentication/113/12 "2008-09-05T09:44:30Z")
try the following. Im not sure if it will work as I am not is a position to test it.
Add a couple of logs to the sql bit of the code to see if the values are getting Through:
```auto
try
{
getLogger().info("userName @ sql: "+userName);
getLogger().info("password @ sql: "+passpword);
String sql = "SELECT count(*) as userCount FROM users where username = '"+userName+"' and password = '"+password+"'";
getLogger().info("sql: "+sql);
stmt = conn.createStatement(sql);
rs = stmt.executeQuery();
if (rs.next() == true) {
if (rs.getInt("userCount") > 0)
{
client.acceptConnection();
}
}
} catch (SQLException sqlEx) {
```
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 9:55am UTC](https://community.wowza.com/t/user-authentication/113/13 "2008-09-05T09:55:09Z")
Some more logger info.
```auto
try
{
getLogger().info("userName @ sql: "+userName);
getLogger().info("password @ sql: "+passpword);
String sql = "SELECT count(*) as userCount FROM users where username = '"+userName+"' and password = '"+password+"'";
getLogger().info("sql: "+sql);
stmt = conn.createStatement(sql);
rs = stmt.executeQuery();
getLogger().info("rs: "+rs.toString());
if (rs.next() == true) {
getLogger().info("rs returns recordset");
if (rs.getInt("userCount") > 0)
{
getLogger().info("which contains at least 1 record so connection should be accepted");
client.acceptConnection();
}
else
{
getLogger().info("but it is empty. Wrong username or password maybe");
}
}
} catch (SQLException sqlEx) {
getLogger().error("sqlexecuteException: " + sqlEx.toString());
}
```
you can never have too much information.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 10:36am UTC](https://community.wowza.com/t/user-authentication/113/14 "2008-09-05T10:36:05Z")
```auto
INFO server comment - userName @ sql: null
INFO server comment - password @ sql: null
```
This is the username & password from the client params. some reason they are not getting through.
```auto
{
String userName = getParamString(params, PARAM1);
String password = getParamString(params, PARAM2);
getLogger().info("params: "+params.toString());
// preload the driver class
```
Add another logger to the onConnect to see what the params are.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 11:26am UTC](https://community.wowza.com/t/user-authentication/113/15 "2008-09-05T11:26:02Z")
```auto
INFO session connect-pending 61.95.197.159 -
INFO server comment - params: AMFDataList:
[0] connect
[1] 1.0
[2] object
{Obj[]: app: "rtplive", flashVer: "WIN 9,0,124,0", swfUrl: "http://72.348.410.254/WOWZA/RTP/nativertp.swf", tcUrl: "rtmp://72.348.410.254/rtplive", fpad: false, capabilities: 15.0, audioCodecs: 1639.0, videoCodecs: 252.0, videoFunction: 1.0 , pageUrl: "http://72.348.410.254/WOWZA/RTP/index.html"}
[3] undefined
[4] undefined
```
[3] is PARAM1 (username) &
[4] is PARAM2 (password).
add some traces to the flash code to check if these values are set properly.
```auto
function connectLivePlayer()
{
if (nc == null)
{
nc = new NetConnection();
nc.connect(serverText.text,User.text,Pwd.text);
trace('User.text: '+User.text);
trace('Pwd.text: '+Pwd.text);
:
:
:
```
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 11:59am UTC](https://community.wowza.com/t/user-authentication/113/16 "2008-09-05T11:59:53Z")
Can you create a new empty flash document and put the following into the actionscript.
```auto
var nc:NetConnection = new NetConnection();
nc.onStatus = function(info) {
for(var i in info) trace(i+": "+info[i]);
}
var conn:String = "rtmp://server-ip/rtplive"; // change to suit
var user:String = "monty"; // I assume thes are the user & pass in the database.
var pass:String = "greatsqldb";
nc.connect(conn, user, pass);
```
run it with Ctrl-Enter from flash and post what shows in the output panel & the server output again
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 12:17pm UTC](https://community.wowza.com/t/user-authentication/113/17 "2008-09-05T12:17:42Z")
can you make sure that it is an AS2 flash document and not AS3
Im using flash 8 which the above works.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 12:24pm UTC](https://community.wowza.com/t/user-authentication/113/18 "2008-09-05T12:24:19Z")
Is there any server output to go with the above?
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 12:43pm UTC](https://community.wowza.com/t/user-authentication/113/19 "2008-09-05T12:43:45Z")
Also, have you set up the server to only accept connection from certian IP’s
This mybe why the above doesnt work but you should still see debug code.
You may need to upload it to test.
---
### Author:  [@Roger\_Littin](https://community.wowza.com/u/Roger_Littin)
#### Post date: [September 5, 2008, 1:42pm UTC](https://community.wowza.com/t/user-authentication/113/20 "2008-09-05T13:42:08Z")
Double check your fla document again.
I think it is strange that you define a value for User.text & PWD.text but they show as undefined.
Make sure that you have given the text fields that are on the stage an instance name so that you can refer to them in code.
Roger.
[Next page](https://community.wowza.com/t/user-authentication/113.md?page=2)