java – 使用外部jar的wowza authontication

Have I missed any steps?

Wowza API具有AuthenticateUsernamePasswordProviderBase类,您需要扩展该类以集成数据库身份验证.

How to call method in the jar file in the time of Wowza authentication?

RTSP身份验证当前在Wowza中的工作方式是指定要在应用程序配置中使用的身份验证方法(在文件的Root / Application / RTP / Authentication / PublishMethod部分中).这些发布方法在身份验证配置中定义.要使用自定义身份验证模块拦截此操作,您需要将Java类作为属性添加到此Authentication.xml文件中.在Wowza的第3版中,Authentication.xml文件位于conf /目录中并且可以轻松编辑,但在版本4中,这已经捆绑到com.wowza.wms.conf包中(您可以从中获取副本)打包并将其复制到您的conf /文件夹,它将覆盖包中的那个).因此,Wowza将使用您的类中定义的方法而不是内置方法.

How to get the username and password from the above command to my method?

当Wowza收到传入的RTSP连接时,它应该从连接中查询用户名/密码并将它们传递给Java类来处理身份验证.

集成数据库以进行身份??验证的示例代码如下：

package com.wowza.wms.example.authenticate;

import com.wowza.wms.authentication.*;
import com.wowza.wms.logging.WMSLoggerFactory; 
import java.sql.*;

public class AuthenticateUsernamePasswordProviderExample extends AuthenticateUsernamePasswordProviderBase
{
public String getPassword(String username)
{
    // return password for given username       
    String pwd = null;

    WMSLoggerFactory.getLogger(null).info("Authenticate getPassword username: " + username);

    Connection conn = null;
    try 
    {
        conn = DriverManager.getConnection("jdbc:mysql://localhost/wowza?user=root&password=mypassword");

        Statement stmt = null;
        ResultSet rs = null;

        try 
        {
            stmt = conn.createStatement();
            rs = stmt.executeQuery("SELECT pwd FROM users where username = '"+username+"'");
            while (rs.next())
            {
                pwd = rs.getString("pwd");
            }

        } 
        catch (SQLException sqlEx) 
        {
            WMSLoggerFactory.getLogger(null).error("sqlexecuteException: " + sqlEx.toString());
        } 
        finally 
        {
            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());
    }

    return pwd;
}

public boolean userExists(String username)
{
    // return true is user exists
    return false;
}
}