AccelByte Java SDK

A software development kit (SDK) for interacting with AccelByte services written in Java.

This SDK was generated from OpenAPI spec included in the spec directory.

Setup

This SDK is developed using JDK 8 and Gradle 7.5.

Gradle

Add the required configuration in gradle.build. Replace {VERSION} with a specific release version tag from releases without the leading v character.

For v0.18.0 and later

The artifacts are published in Maven Central.

repositories {
   mavenCentral()
}

dependencies {
   implementation 'net.accelbyte.sdk:sdk:{VERSION}'
}

For v0.17.0 and earlier

The artifacts are moved to AccelByte Internal Nexus. You need to request for {USERNAME} and {PASSWORD} to be able to access it.

repositories {
   mavenCentral()
   maven {
      url 'https://nexus.tools.accelbyte.net/repository/maven-releases/'
      credentials {
         username = '{USERNAME}'
         password = '{PASSWORD}'
      }
   }
}

dependencies {
   implementation 'net.accelbyte.sdk:sdk:{VERSION}'
}

Environment Variables

The following environment variables need to be set when using DefaultConfigRepository.

Name	Required	Example
AB_BASE_URL	Yes	https://test.accelbyte.io
AB_CLIENT_ID	Yes	abcdef0123456789abcdef0123456789
AB_CLIENT_SECRET	Yes, but only if you use a confidential AB_CLIENT_ID	ab#c,d)ef(ab#c,d)ef(ab#c,d)ef(ab

Usage

Instantiation

With Default HTTP Client (OkhttpClient)

Use the following to get SDK instance with basic HTTP functionality.

AccelByteConfig config = new AccelByteConfig(
      new OkhttpClient(),
      DefaultTokenRepository.getInstance(),
      new DefaultConfigRepository());     // Using DefaultConfigRepository, make sure the required environment variables are set

AccelByteSDK sdk = new AccelByteSDK(config);

With Reliable HTTP client

Use the following to get SDK instance with HTTP retry functionality.

final DefaultHttpRetryPolicy retryPolicy = new DefaultHttpRetryPolicy();

retryPolicy.setCallTimeout(3000);   // In milliseconds
retryPolicy.setMaxRetry(3);
retryPolicy.setRetryInterval(2000);    // In milliseconds
retryPolicy.setRetryIntervalType(RetryIntervalType.LINEAR);    // LINEAR, EXPONENTIAL are available

private final ReliableHttpClient reliableHttpClient = new ReliableHttpClient(retryPolicy);

AccelByteConfig config = new AccelByteConfig(
      reliableHttpClient,
      DefaultTokenRepository.getInstance(),
      new DefaultConfigRepository());     // Using DefaultConfigRepository, make sure the required environment variables are set

AccelByteSDK sdk = new AccelByteSDK(config);

Automatic Token Refresh

Use the following to get SDK instance with automatic token refresh functionality which is performed before each HTTP request but only if access token is almost expired.

AccelByteConfig config = new AccelByteConfig(
      new OkhttpClient(),
      new DefaultTokenRefreshRepository();   // Using DefaultTokenRefreshRepository which implements TokenRefresh interface to enable automatic token refresh
      new DefaultConfigRepository());     // Using DefaultConfigRepository, make sure the required environment variables are set

AccelByteSDK sdk = new AccelByteSDK(config);

On-demand Refresh Token (Preview)

The on-demand refresh token is intended to be used in environment where automatic refresh token cannot work properly e.g. AWS Lambda.`

DefaultConfigRepository configRepo = new DefaultConfigRepository();
// Must use this if you want to use LoginOrRefresh
DefaultTokenRefreshRepository refreshRepo = new DefaultTokenRefreshRepository();
AccelByteConfig config = new AccelByteConfig(new OkhttpClient(), refreshRepo, configRepo);
AccelByteSDK sdk = new AccelByteSDK(config);
// Before making endpoint call
// Either use this for user credentials
boolean result = sdk.loginOrRefreshUser("username", "password");
// Or this for client credentials
boolean result = sdk.loginOrRefreshClient();

You can refer to this example of more details, sample login or refresh

Local Token Validation

To enable local token validation, use the following when instantiating the SDK. When enabled, the SDK instance will cache JWKS and revocation list for performing token validation so that it does not have to call AccelByte Gaming Services endpoint each time. See Validate Access Token section on how to validate token using SDK.

final DefaultConfigRepository defaultConfigRepository = new DefaultConfigRepository();    // Using DefaultConfigRepository, make sure the required environment variables are set

defaultConfigRepository.setLocalTokenValidationEnabled(true);     // Enable local token validation
defaultConfigRepository.setJwksRefreshInterval(300);    // Refresh JWKS for local token validation every 5 minutes
defaultConfigRepository.setRevocationListRefreshInterval(300);    // Refresh revocation list for local token validation every 5 minutes

AccelByteConfig config = new AccelByteConfig(
      new OkhttpClient(),
      DefaultTokenRepository.getInstance(),
      defaultConfigRepository);

AccelByteSDK sdk = new AccelByteSDK(config);

Login

Login Using Username and Password

boolean login = sdk.loginUser("myUsername", "myPassword");

if (!login) {
    // Login failed  
}

Login Using Username and Password with Specific Scope

boolean login = sdk.loginUser("myUsername", "myPassword", "scopeA scopeB");   // Space separated scope values

if (!login) {
    // Login failed  
}

Login Using OAuth Client

boolean login = sdk.loginClient();

if (!login) {
    // Login failed   
}

⚠️ Please use loginClient() function with confidential OAuth client: Using loginClient() function with public OAuth client is not supported.

Validate Access Token

To validate if an access token is valid and has the required permission, use the ValidateToken method of AccelByteSDK instance. To validate an access token without validating the required permission, omit the optional permission and action parameters of ValidateToken method. By default, remote token validation is performed. However, if higher throughput is required, you may enable local token validation as mentioned in Local Token Validation section. With local token validation, token validation will be quicker at the expense of delayed revocation list update (a revoked token may still be regarded as valid until local cache of the revocation list is updated).

boolean isOk = sdk.validateToken("token", "ADMIN:NAMESPACE:serversdktest:INFORMATION:USER:abdedef", 2);  // Validate token

if (isOk) {
    // Token is valid and has the required permission
}
else {
   // Token is not valid or expired or does not have the required permission
}

Parse Access Token

Use the following to parse access token and get its payload.

AccessTokenPayload payload = sdk.parseAccessToken("access token", false);

// Or if token validation is required before parsing, then use the following

AccessTokenPayload payload = sdk.parseAccessToken("access token", true);

The payload will be null if the parse failed or when validation is required, and it failed.

Interacting with a Service Endpoint

As an example, we will get current user profile info using getMyProfileInfo endpoint available in basic service.

// Login using username and password

boolean login = sdk.loginUser("myUsername", "myPassword");

if (!login) {
      System.out.println("login failed");
      return;
}

// Instantiate UserProfile wrapper class which is part of basic service

UserProfile userProfile = new UserProfile(sdk);

try {
   // Make a call to getMyProfileInfo endpoint
   UserProfilePrivateInfo response = userProfile
         .getMyProfileInfo(new GetMyProfileInfo("accelbyte"));

   System.out.println(response.getUserId());    // Success response

} catch (HttpResponseException e) {     // Error response from the service
   e.printStackTrace();

   if (e.getHttpCode() == 400) {
      // Handle specific error response HTTP code
   }

} catch (IOException e) {     // Network error
   e.printStackTrace();    
}

Refresh Token Manually

boolean isOk = sdk.refreshToken();  // Trigger token refresh manually when not using automatic token refresh functionality

if (isOk) {
    // Refresh token is succesful or not required
}
else {
   // Refresh token failed
}

Logout

boolean logout = sdk.logout();

if (!logout) {
    // Logout failed
}

Websocket

• Automatic Ping Interval: by default, automatic ping frames are not sent.

  To enable the feature, for the LobbyWebSocketClient.create() call, simply pass in:

  • pingIntervalMs > 0 to set the number of seconds between each automatic ping (until the connection is closed)
  • pingIntervalMs = 0 means disabled

• Websocket Reconnection: Websocket Reconnection is a feature to help support auto-reconnection on websocket disconnects resulting from RFC 6455 status codes between 1001 to 2999. By default, the feature is off.

  To enable the feature, for the LobbyWebSocketClient.create() call, simply pass in:

  • reconnectDelayMs > 0 to control the delay between each reconnect attempt (with exponential backoff)
  • reconnectDelayMs = 0 means disabled
  • maxNumReconnectAttempts to control the maximum number of reconnection attempts
  • maxNumReconnectAttempts = -1 means unlimited reconnect attempts (reconnectDelayMs must be > 0 to enable)

Example:

final WebSocketListener listener =
    new WebSocketListener() {
        @Override
        public void onMessage(@NotNull WebSocket webSocket, @NotNull String text) {
            log.info("Received onMessage: " + text);
            ...
        }
    };

final int RECONNECT_DELAY_MS = 60000;  // 1m (0 to disable)
final int MAX_NUM_RECONNECT_ATTEMPTS = 10; // -1 for unlimited reconnect attempts (RECONNECT_DELAY_MS must be > 0 to enable)

final int PING_INTERVAL_MS = 30000;  // 30s (0 to disable)

final LobbyWebSocketClient ws =
        LobbyWebSocketClient.create(
            new DefaultConfigRepository(), DefaultTokenRepository.getInstance(), listener, RECONNECT_DELAY_MS, MAX_NUM_RECONNECT_ATTEMPTS, PING_INTERVAL_MS);

ws.connect();

final String requestMessage = PartyCreateRequest.builder().id(request_id).build().toWSM();
ws.sendMessage(requestMessage);
...

Lobby session preservation logic upon reconnect: In the event of a disconnection and a reconnection, the previous lobby session id will be requested for reuse via the "X-Ab-LobbySessionID" header with the cached value from the previous lobby session.

Samples

Sample apps are available in the samples directory.

Documentation

Reference about AccelByte service endpoints and their corresponding SDK API is available in docs/operations directory.

For more information on how to use AccelByte services and SDKs, see docs.accelbyte.io.