/**
 * 连接FTP服务器
 * @param host
 * @param port
 * @param userName
 * @param password
 * @return 连接成功返回TRUE，失败返回FALSE
 */
public boolean connect(String host, int port, String userName, String password) {
	boolean result = true;
	try {
		client.connect(host, port);
		int code = client.getReplyCode();
		if (FTPReply.isPositiveCompletion(code)) {
			if (client.login(userName, password)) {
				log.info("连接并登陆上FTP服务器" + host + ":" + port);
			} else {
				log.info("登录FTP服务器失败" + host + ":" + port);
				result = false;
			}
		} else {
			log.info("连接FTP服务器失败，关闭连接" + host + ":" + port);
			result = false;
			disconnect();
		}
	} catch (Exception e) {
		// TODO: handle exception
		disconnect();
		log.error("Exception:", e);
		return false;
	}
 
	return result;
}

/**
* 与FTP服务器断开连接
*
*/
public void disconnect() {
	// TODO Auto-generated method stub
	try {
		if (client.isConnected()) {
			client.logout();
			client.disconnect();
		}
		log.info("与FTP服务器连接已关闭！");
	} catch (Exception e) {
		// TODO: handle exception
		log.error("Exception:", e);
	}
}

/**
 * 上传指定文件到服务器，服务器目录为根目录，并且本地文件与上传到服务器的文件名称相同
* @param local	本地文件相对路径，包含文件名
* @return
*/
public boolean upload(String local) {
	try {
		// 设置成服务器被动相应模式
		client.enterLocalPassiveMode();
 
		// 文件类型设为二进制类型
		client.setFileType(FTP.BINARY_FILE_TYPE);
 
		String fileName = local.substring(local.lastIndexOf("/") + 1);
 
		FTPFile[] files = client.listFiles(fileName);
 
		if (files.length > 0) {
			log.info(fileName + "文件已存在，不进行上传！");
			return false;
		}
 
		File file = new File(local);
		InputStream is = new FileInputStream(file);
 
		if (client.storeFile(fileName, is)) {
			log.info(fileName + "文件上传成功！");
			is.close();
			return true;
		} else {
			log.info(fileName + "文件上传失败！");
			is.close();
			return false;
		}
 
	} catch (Exception e) {
		// TODO: handle exception
		log.error("Exception:", e);
		return false;
	}
}

/**
 * 上传本地文件到服务器上的指定目录，可以修改文件名称，若服务器上目录不存在，则自动创建指定的目录结构
 * @param local 本地文件的相对路径，包含文件名
* @param remote 服务器上的文件路径，包含文件名
 * @return 上传成功返回TRUE，失败返回FALSE
 */
public boolean upload(String local, String remote) {
	try {
		client.enterLocalPassiveMode();
		client.setFileType(FTP.BINARY_FILE_TYPE);
 
		String remoteFileName = remote;
 
		if (remote.contains("/")) {
			remoteFileName = remote.substring(remote.lastIndexOf("/") + 1);
			String remoteDirectory = remote.substring(0, remote.lastIndexOf("/") + 1);
 
			// 判断远程目录是否存在，若不存在则循环创建
			if (!remoteDirectory.equalsIgnoreCase("/")
					&& !client.changeWorkingDirectory(remoteDirectory)) {
                                                   // 目录结构索引
				int start = 0;
				int end  = 0;
				String subDir = "";
 
				if (remoteDirectory.startsWith("/")) {
					start = 1;
				} else {
					start = 0;
				}
				end = remoteDirectory.indexOf("/", start);
 
				while (true) {
					subDir = remoteDirectory.substring(start, end);
 
					if (!client.changeWorkingDirectory(subDir)) {
						if (client.makeDirectory(subDir)) {
							client.changeWorkingDirectory(subDir);
						} else {
							log.info(subDir + "目录创建失败！");
							return false;
						}
					}
 
					start = end + 1;
					end = remoteDirectory.indexOf("/", start);
 
					if (end < start) {            // 到目录结尾
						break;
					}
				}
			}
		}
 
		FTPFile[] files = client.listFiles(remoteFileName);
 
		if (files.length > 0) {
			log.info(remoteFileName + "文件已存在，不进行上传！");
			return false;
		}
 
		File file = new File(local);
		InputStream is = new FileInputStream(file);
 
		if (client.storeFile(remoteFileName, is)) {
			log.info(remoteFileName + "文件上传成功！");
			is.close();
			return true;
		} else {
			log.info(remoteFileName + "文件上传失败！");
			is.close();
			return false;
		}
 
	} catch (Exception e) {
		// TODO: handle exception
		log.error("Exception", e);
		return false;
	}
 
}

public static void main(String[] a) {
	FtpConnection ftp = new FtpConnection();
	ftp.connect("57.27.5.44", 21, "123", "456");
	ftp.upload("upload/mysql-5.0.86-win32.zip", "/dir/text/mysql-5.0.86-win32.zip");
	ftp.disconnect();
}

String res = "0|";
 
if(responseMessage != null && responseMessage.getStatus() == SmsMessage.STATUS_NORMAL){
    res = res + responseMessage.getContentString();
}
 
res = new String(res.getBytes("UTF-8"), "UTF-8");
response.setContentType("text/plain; charset=utf-8");
response.getWriter().write(res);

byte[] bs = res.get().getStringContent().getBytes();
String result = new String(bs, "UTF-8");

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.swordworld;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.DataManager;
import com.sun.sgs.app.ManagedReference;
/**
* A tiny sample MUD application for the Project Darkstar Server.
*
 
* There is a Room. In the Room there is a Sword...
*/
public class SwordWorld
implements Serializable, AppListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(SwordWorld.class.getName());
 
/** A reference to the one-and-only {@linkplain SwordWorldRoom room}. */
private ManagedReference roomRef = null;
 
/**
* {@inheritDoc}
*
 
* Creates the world within the MUD.
*/
public void initialize(Properties props) {
logger.info("Initializing SwordWorld");
// Create the Room
SwordWorldRoom room =
new SwordWorldRoom("Plain Room", "a nondescript room");
 
// Create the Sword
SwordWorldObject sword =
new SwordWorldObject("Shiny Sword", "a shiny sword.");
 
// Put the Sword to the Room
room.addItem(sword);
 
// Keep a reference to the Room
setRoom(room);
logger.info("SwordWorld Initialized");
}
/**
* Gets the SwordWorld's One True Room.
*
 
* @return the room for this {@code SwordWorld}
*/
public SwordWorldRoom getRoom() {
if (roomRef == null)
return null;
return roomRef.get();
}
/**
* Sets the SwordWorld's One True Room to the given room.
*
 
* @param room the room to set
*/
public void setRoom(SwordWorldRoom room) {
DataManager dataManager = AppContext.getDataManager();
if (room == null) {
roomRef = null;
return;
}
roomRef = dataManager.createReference(room);
}
/**
* {@inheritDoc}
*
 
* Obtains the {@linkplain SwordWorldPlayer player} for this
* {@linkplain ClientSession session}'s user, and puts the
* player into the One True Room for this {@code SwordWorld}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
logger.log(Level.INFO,
"SwordWorld Client login: {0}", session.getName());
 
// Delegate to a factory method on SwordWorldPlayer,
// since player management really belongs in that class.
SwordWorldPlayer player = SwordWorldPlayer.loggedIn(session);
 
// Put player in room
player.enter(getRoom());
 
// return player object as listener to this client session
return player;
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.swordworld;
import java.io.Serializable;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.ManagedObject;
/**
* A {@code ManagedObject} that has a name and a description.
*/
public class SwordWorldObject
implements Serializable, ManagedObject
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The name of this object. */
private String name;
 
/** The description of this object. */
private String description;
 
/**
* Creates a new {@code SwordWorldObject} with the given {@code name}
* and {@code description}.
*
* @param name the name of this object
* @param description the description of this object
*/
public SwordWorldObject(String name, String description) {
this.name = name;
this.description = description;
}
/**
* Sets the name of this object.
*
* @param name the name of this object
*/
public void setName(String name) {
AppContext.getDataManager().markForUpdate(this);
this.name = name;
}
/**
* Returns the name of this object.
*
* @return the name of this object
*/
public String getName() {
return name;
}
/**
* Sets the description of this object.
*
* @param description the description of this object
*/
public void setDescription(String description) {
AppContext.getDataManager().markForUpdate(this);
this.description = description;
}
/**
* Returns the description of this object.
*
* @return the description of this object
*/
public String getDescription() {
return description;
}
/** {@inheritDoc} */
@Override
public String toString() {
return getName();
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.swordworld;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.DataManager;
import com.sun.sgs.app.ManagedReference;
/**
* Represents a room in the {@link SwordWorld} example MUD.
*/
public class SwordWorldRoom extends SwordWorldObject
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(SwordWorldRoom.class.getName());
 
/** The set of items in this room. */
private final Set> items =
new HashSet>();
 
/** The set of players in this room. */
private final Set> players =
new HashSet>();
/**
* Creates a new room with the given name and description, initially
* empty of items and players.
*
* @param name the name of this room
* @param description a description of this room
 
*/
public SwordWorldRoom(String name, String description) {
super(name, description);
}
/**
* Adds an item to this room.
*
* @param item the item to add to this room.
* @return {@code true} if the item was added to the room
*/
public boolean addItem(SwordWorldObject item) {
logger.log(Level.INFO, "{0} placed in {1}",
new Object[] { item, this });
 
// NOTE: we can't directly save the item in the list, or
// we'll end up with a local copy of the item. Instead, we
// must save a ManagedReference to the item.
DataManager dataManager = AppContext.getDataManager();
dataManager.markForUpdate(this);
return items.add(dataManager.createReference(item));
}
/**
* Adds a player to this room.
*
* @param player the player to add
* @return {@code true} if the player was added to the room
*/
public boolean addPlayer(SwordWorldPlayer player) {
logger.log(Level.INFO, "{0} enters {1}",
new Object[] { player, this });
DataManager dataManager = AppContext.getDataManager();
dataManager.markForUpdate(this);
return players.add(dataManager.createReference(player));
}
/**
* Removes a player from this room.
*
* @param player the player to remove
* @return {@code true} if the player was in the room
*/
public boolean removePlayer(SwordWorldPlayer player) {
logger.log(Level.INFO, "{0} leaves {1}",
new Object[] { player, this });
DataManager dataManager = AppContext.getDataManager();
dataManager.markForUpdate(this);
return players.remove(dataManager.createReference(player));
}
/**
* Returns a description of what the given player sees in this room.
*
* @param looker the player looking in this room
* @return a description of what the given player sees in this room
*/
public String look(SwordWorldPlayer looker) {
logger.log(Level.INFO, "{0} looks at {1}",
new Object[] { looker, this });
StringBuilder output = new StringBuilder();
output.append("You are in ").append(getDescription()).append(".\n");
List otherPlayers = getPlayersExcluding(looker);
if (! otherPlayers.isEmpty()) {
output.append("Also in here are ");
appendPrettyList(output, otherPlayers);
output.append(".\n");
}
if (! items.isEmpty()) {
output.append("On the floor you see:\n");
for (ManagedReference itemRef : items) {
SwordWorldObject item = itemRef.get();
output.append(item.getDescription()).append('\n');
}
}
return output.toString();
}
/**
* Appends the names of the {@code SwordWorldObject}s in the list
* to the builder, separated by commas, with an "and" before the final
* item.
*
* @param builder the {@code StringBuilder} to append to
* @param list the list of items to format
*/
private void appendPrettyList(StringBuilder builder,
List<!--xtends SwordWorldObje--> list)
{
if (list.isEmpty()) {
return;
}
int lastIndex = list.size() - 1;
SwordWorldObject last = list.get(lastIndex);
Iterator<!--xtends SwordWorldObje--> it =
list.subList(0, lastIndex).iterator();
if (it.hasNext()) {
SwordWorldObject other = it.next();
builder.append(other.getName());
while (it.hasNext()) {
other = it.next();
builder.append(" ,");
builder.append(other.getName());
}
builder.append(" and ");
}
builder.append(last.getName());
}
/**
* Returns a list of players in this room excluding the given
* player.
*
* @param player the player to exclude
* @return the list of players
*/
private ListgetPlayersExcluding(SwordWorldPlayer player)
{
if (players.isEmpty()) {
return Collections.emptyList();
}
ArrayList otherPlayers =
new ArrayList(players.size());
for (ManagedReference playerRef : players) {
SwordWorldPlayer other = playerRef.get();
if (!player.equals(other)) {
otherPlayers.add(other);
}
}
return Collections.unmodifiableList(otherPlayers);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.swordworld;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.DataManager;
import com.sun.sgs.app.ManagedReference;
import com.sun.sgs.app.NameNotBoundException;
/**
* Represents a player in the {@link SwordWorld} example MUD.
*/
public class SwordWorldPlayer
extends SwordWorldObject
implements ClientSessionListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(SwordWorldPlayer.class.getName());
 
/** The message encoding. */
public static final String MESSAGE_CHARSET = "UTF-8";
 
/** The prefix for player bindings in the {@code DataManager}. */
protected static final String PLAYER_BIND_PREFIX = "Player.";
 
/** The {@code ClientSession} for this player, or null if logged out. */
private ManagedReference currentSessionRef = null;
 
/** The {@link SwordWorldRoom} this player is in, or null if none. */
private ManagedReference currentRoomRef = null;
 
/**
* Find or create the player object for the given session, and mark
* the player as logged in on that session.
*
* @param session which session to find or create a player for
* @return a player for the given session
*/
public static SwordWorldPlayer loggedIn(ClientSession session) {
String playerBinding = PLAYER_BIND_PREFIX + session.getName();
// try to find player object, if non existent then create
DataManager dataMgr = AppContext.getDataManager();
SwordWorldPlayer player;
try {
player = (SwordWorldPlayer) dataMgr.getBinding(playerBinding);
} catch (NameNotBoundException ex) {
// this is a new player
player = new SwordWorldPlayer(playerBinding);
logger.log(Level.INFO, "New player created: {0}", player);
dataMgr.setBinding(playerBinding, player);
}
player.setSession(session);
return player;
}
/**
* Creates a new {@code SwordWorldPlayer} with the given name.
*
* @param name the name of this player
*/
protected SwordWorldPlayer(String name) {
super(name, "Seeker of the Sword");
}
/**
* Returns the session for this listener.
*
* @return the session for this listener
*/
protected ClientSession getSession() {
if (currentSessionRef == null) {
return null;
}
return currentSessionRef.get();
}
/**
* Mark this player as logged in on the given session.
*
* @param session the session this player is logged in on
*/
protected void setSession(ClientSession session) {
DataManager dataMgr = AppContext.getDataManager();
dataMgr.markForUpdate(this);
currentSessionRef = dataMgr.createReference(session);
logger.log(Level.INFO, "Set session for {0} to {1}",
new Object[] { this, session });
}
/**
* Handles a player entering a room.
*
* @param room the room for this player to enter
*/
public void enter(SwordWorldRoom room) {
logger.log(Level.INFO, "{0} enters {1}",
new Object[] { this, room }
);
room.addPlayer(this);
setRoom(room);
}
/** {@inheritDoc} */
public void receivedMessage(ByteBuffer message) {
String command = decodeString(message);
logger.log(Level.INFO, "{0} received command: {1}",
new Object[] { this, command }
);
if (command.equalsIgnoreCase("look")) {
String reply = getRoom().look(this);
getSession().send(encodeString(reply));
} else {
logger.log(Level.WARNING, "{0} unknown command: {1}",
new Object[] { this, command }
);
// We could disconnect the rogue player at this point.
//currentSession.disconnect();
}
}
/** {@inheritDoc} */
public void disconnected(boolean graceful) {
setSession(null);
logger.log(Level.INFO, "Disconnected: {0}", this);
getRoom().removePlayer(this);
setRoom(null);
}
/**
* Returns the room this player is currently in, or {@code null} if
* this player is not in a room.
*
 
* @return the room this player is currently in, or {@code null}
*/
protected SwordWorldRoom getRoom() {
if (currentRoomRef == null) {
return null;
}
return currentRoomRef.get();
}
/**
* Sets the room this player is currently in. If the room given
* is null, marks the player as not in any room.
*
 
* @param room the room this player should be in, or {@code null}
*/
protected void setRoom(SwordWorldRoom room) {
DataManager dataManager = AppContext.getDataManager();
dataManager.markForUpdate(this);
if (room == null) {
currentRoomRef = null;
return;
}
currentRoomRef = dataManager.createReference(room);
}
/** {@inheritDoc} */
@Override
public String toString() {
StringBuilder buf = new StringBuilder(getName());
buf.append('@');
if (getSession() == null) {
buf.append("null");
} else {
buf.append(currentSessionRef.getId());
}
return buf.toString();
}
/**
* Encodes a {@code String} into a {@link ByteBuffer}.
*
* @param s the string to encode
* @return the {@code ByteBuffer} which encodes the given string
*/
protected static ByteBuffer encodeString(String s) {
try {
return ByteBuffer.wrap(s.getBytes(MESSAGE_CHARSET));
} catch (UnsupportedEncodingException e) {
throw new Error("Required character set " + MESSAGE_CHARSET +
" not found", e);
}
}
/**
* Decodes a message into a {@code String}.
*
* @param message the message to decode
* @return the decoded string
*/
protected static String decodeString(ByteBuffer message) {
try {
byte[] bytes = new byte[message.remaining()];
message.get(bytes);
return new String(bytes, MESSAGE_CHARSET);
} catch (UnsupportedEncodingException e) {
throw new Error("Required character set " + MESSAGE_CHARSET +
" not found", e);
}
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.lesson6;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.Channel;
import com.sun.sgs.app.ChannelManager;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.Delivery;
import com.sun.sgs.app.ManagedReference;
/**
* Simple example of channel operations in the Project Darkstar Server.
*
 
* Extends the {@code HelloEcho} example by joining clients to two
* channels.
*/
public class HelloChannels
implements Serializable, AppListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloChannels.class.getName());
 
/* The name of the first channel {@value #CHANNEL_1_NAME} */
static final String CHANNEL_1_NAME = "Foo";
 
/* The name of the second channel {@value #CHANNEL_2_NAME} */
static final String CHANNEL_2_NAME = "Bar";
 
/**
* The first {@link Channel}. The second channel is looked up
* by name.
*/
private ManagedReference channel1 = null;
 
/**
* {@inheritDoc}
*
 
* Creates the channels. Channels persist across server restarts,
* so they only need to be created here in {@code initialize}.
*/
public void initialize(Properties props) {
ChannelManager channelMgr = AppContext.getChannelManager();
 
// Create and keep a reference to the first channel.
Channel c1 = channelMgr.createChannel(CHANNEL_1_NAME,
null,
Delivery.RELIABLE);
channel1 = AppContext.getDataManager().createReference(c1);
 
// We don't keep a reference to the second channel, to demonstrate
// looking it up by name when needed. Also, this channel uses a
// {@link ChannelListener} to filter messages.
channelMgr.createChannel(CHANNEL_2_NAME,
new HelloChannelsChannelListener(),
Delivery.RELIABLE);
}
/**
* {@inheritDoc}
*
 
* Returns a {@link HelloChannelsSessionListener} for the
* logged-in session.
*/
public ClientSessionListener loggedIn(ClientSession session) {
logger.log(Level.INFO, "User {0} has logged in", session.getName());
return new HelloChannelsSessionListener(session, channel1);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.lesson6;
import java.io.Serializable;
import java.nio.ByteBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.Channel;
import com.sun.sgs.app.ChannelManager;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.DataManager;
import com.sun.sgs.app.ManagedReference;
/**
* Simple example {@link ClientSessionListener} for the Project Darkstar
* Server.
*
 
* Logs each time a session receives data or logs out, and echoes
* any data received back to the sender.
*/
class HelloChannelsSessionListener
implements Serializable, ClientSessionListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloChannelsSessionListener.class.getName());
 
/** The session this {@code ClientSessionListener} is listening to. */
private final ManagedReference sessionRef;
 
/** The name of the {@code ClientSession} for this listener. */
private final String sessionName;
/**
* Creates a new {@code HelloChannelsSessionListener} for the session.
*
* @param session the session this listener is associated with
* @param channel1 a reference to a channel to join
*/
public HelloChannelsSessionListener(ClientSession session,
ManagedReference channel1)
{
if (session == null) {
throw new NullPointerException("null session");
}
DataManager dataMgr = AppContext.getDataManager();
sessionRef = dataMgr.createReference(session);
sessionName = session.getName();
 
// Join the session to all channels. We obtain the channel
// in two different ways, by reference and by name.
ChannelManager channelMgr = AppContext.getChannelManager();
 
// We were passed a reference to the first channel.
channel1.get().join(session);
 
// We look up the second channel by name.
Channel channel2 = channelMgr.getChannel(HelloChannels.CHANNEL_2_NAME);
channel2.join(session);
}
/**
* Returns the session for this listener.
*
* @return the session for this listener
*/
protected ClientSession getSession() {
// We created the ref with a non-null session, so no need to check it.
return sessionRef.get();
}
/**
* {@inheritDoc}
*
 
* Logs when data arrives from the client, and echoes the message back.
*/
public void receivedMessage(ByteBuffer message) {
ClientSession session = getSession();
if (logger.isLoggable(Level.FINE)) {
logger.log(Level.FINE, "Message from {0}", sessionName);
}
session.send(message);
}
/**
* {@inheritDoc}
*
 
* Logs when the client disconnects.
*/
public void disconnected(boolean graceful) {
String grace = graceful ? "graceful" : "forced";
logger.log(Level.INFO,
"User {0} has logged out {1}",
new Object[] { sessionName, grace }
);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.lesson6;
import java.io.Serializable;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.Channel;
import com.sun.sgs.app.ChannelListener;
import com.sun.sgs.app.ClientSession;
import java.nio.ByteBuffer;
/**
* Simple example {@link ChannelListener} for the Project Darkstar Server.
*
 
* Logs when a channel receives data.
*/
class HelloChannelsChannelListener
implements Serializable, ChannelListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloChannelsChannelListener.class.getName());
 
/**
* {@inheritDoc}
*
 
* Logs when data arrives on a channel. A typical listener would
* examine the message to decide whether it should be discarded,
* modified, or sent unchanged.
*/
public void receivedMessage(Channel channel,
ClientSession session, ByteBuffer message)
{
if (logger.isLoggable(Level.INFO)) {
logger.log(Level.INFO,
"Channel message from {0} on channel {1}",
new Object[] { session.getName(), channel.getName() }
);
}
channel.send(session, message);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson5;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
/**
* Simple example of listening for user {@linkplain AppListener#loggedIn login}
* in the Project Darkstar Server.
* <p>
* Logs each time a user logs in, then kicks them off immediately.
*/
public class HelloUser
implements AppListener, // to get called during startup and login.
Serializable // since all AppListeners are ManagedObjects.
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloUser.class.getName());
 
// implement AppListener
/** {@inheritDoc} */
public void initialize(Properties props) {
// empty
}
/**
* {@inheritDoc}
* <p>
* Logs a message each time a new session tries to login, then
* kicks them out by returning {@code null}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
// User has logged in
logger.log(Level.INFO, "User {0} almost logged in", session.getName());
// Kick the user out immediately by returning a null listener
return null;
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson5;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
/**
* Simple example of listening for user {@linkplain AppListener#loggedIn login}
* in the Project Darkstar Server.
* <p>
* Logs each time a user logs in, and sets their listener to a
* new {@link HelloUserSessionListener}.
*/
public class HelloUser2
implements AppListener, // to get called during startup and login.
Serializable // since all AppListeners are ManagedObjects.
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloUser2.class.getName());
 
// implement AppListener
/** {@inheritDoc} */
public void initialize(Properties props) {
// empty
}
/**
* {@inheritDoc}
* <p>
* Logs a message each time a new session logs in.
*/
public ClientSessionListener loggedIn(ClientSession session) {
// User has logged in
logger.log(Level.INFO, "User {0} has logged in", session.getName());
// Return a valid listener
return new HelloUserSessionListener(session);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson5;
import java.io.Serializable;
import java.nio.ByteBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.ManagedReference;
/**
* Simple example {@link ClientSessionListener} for the Project Darkstar
* Server.
* <p>
* Logs each time a session receives data or logs out.
*/
class HelloUserSessionListener
implements Serializable, ClientSessionListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloUserSessionListener.class.getName());
 
/** The session this {@code ClientSessionListener} is listening to. */
private final ManagedReference<ClientSession> sessionRef;
 
/** The name of the {@code ClientSession} for this listener. */
private final String sessionName;
 
/**
* Creates a new {@code HelloUserSessionListener} for the given session.
*
* @param session the session this listener is associated with
*/
public HelloUserSessionListener(ClientSession session) {
if (session == null) {
throw new NullPointerException("null session");
}
sessionRef = AppContext.getDataManager().createReference(session);
sessionName = session.getName();
}
/**
* Returns the session for this listener.
*
* @return the session for this listener
*/
protected ClientSession getSession() {
// We created the ref with a non-null session, so no need to check it.
return sessionRef.get();
}
/**
* {@inheritDoc}
* <p>
* Logs when data arrives from the client.
*/
public void receivedMessage(ByteBuffer message) {
logger.log(Level.INFO, "Message from {0}", sessionName);
}
/**
* {@inheritDoc}
* <p>
* Logs when the client disconnects.
*/
public void disconnected(boolean graceful) {
String grace = graceful ? "graceful" : "forced";
logger.log(Level.INFO,
"User {0} has logged out {1}",
new Object[] { sessionName, grace }
);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson5;
import java.io.Serializable;
import java.nio.ByteBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.ManagedReference;
/**
* Simple example {@link ClientSessionListener} for the Project Darkstar
* Server.
* <p>
* Logs each time a session receives data or logs out, and echoes
* any data received back to the sender.
*/
class HelloEchoSessionListener
implements Serializable, ClientSessionListener
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloEchoSessionListener.class.getName());
 
/** The session this {@code ClientSessionListener} is listening to. */
private final ManagedReference<ClientSession> sessionRef;
 
/** The name of the {@code ClientSession} for this listener. */
private final String sessionName;
 
/**
* Creates a new {@code HelloEchoSessionListener} for the given session.
*
* @param session the session this listener is associated with
*/
public HelloEchoSessionListener(ClientSession session) {
if (session == null) {
throw new NullPointerException("null session");
}
sessionRef = AppContext.getDataManager().createReference(session);
sessionName = session.getName();
}
/**
* Returns the session for this listener.
*
* @return the session for this listener
*/
protected ClientSession getSession() {
// We created the ref with a non-null session, so no need to check it.
return sessionRef.get();
}
/**
* {@inheritDoc}
* <p>
* Logs when data arrives from the client, and echoes the message back.
*/
public void receivedMessage(ByteBuffer message) {
ClientSession session = getSession();
logger.log(Level.INFO, "Message from {0}", sessionName);
// Echo message back to sender
session.send(message);
}
/**
* {@inheritDoc}
* <p>
* Logs when the client disconnects.
*/
public void disconnected(boolean graceful) {
String grace = graceful ? "graceful" : "forced";
logger.log(Level.INFO,
"User {0} has logged out {1}",
new Object[] { sessionName, grace }
);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
 
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.lesson4;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.ManagedObject;
import com.sun.sgs.app.Task;
import com.sun.sgs.app.TaskManager;
/**
* A simple persistence example for the Project Darkstar Server.
* As a {@link ManagedObject}, it is able to modify instance fields,
* demonstrated here by tracking the last timestamp at which a task
* was run and displaying the time delta.
*/
public class HelloPersistence
implements AppListener, // to get called during application startup.
Serializable, // since all AppListeners are ManagedObjects.
Task // to schedule future calls to our run() method.
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloPersistence.class.getName());
 
/** The delay before the first run of the task. */
public static final int DELAY_MS = 5000;
 
/** The time to wait before repeating the task. */
public static final int PERIOD_MS = 500;
 
/** The timestamp when this task was last run. */
private long lastTimestamp = System.currentTimeMillis();
 
// implement AppListener
/**
* {@inheritDoc}
*
 
* Schedules the {@code run()} method to be called periodically.
* Since SGS tasks are persistent, the scheduling only needs to
* be done the first time the application is started. When the
* server is killed and restarted, the scheduled timer task will
* continue ticking.
*
 
* Runs the task {@value #DELAY_MS} ms from now,
* repeating every {@value #PERIOD_MS} ms.
*/
public void initialize(Properties props) {
TaskManager taskManager = AppContext.getTaskManager();
taskManager.schedulePeriodicTask(this, DELAY_MS, PERIOD_MS);
}
/**
* {@inheritDoc}
*
 
* Prevents client logins by returning {@code null}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
return null;
}
// implement Task
/**
* {@inheritDoc}
*
 
* Each time this {@code Task} is run, logs the current timestamp and
* the delta from the timestamp of the previous run.
*/
public void run() throws Exception {
long timestamp = System.currentTimeMillis();
long delta = timestamp - lastTimestamp;
 
// Update the field holding the most recent timestamp.
lastTimestamp = timestamp;
logger.log(Level.INFO,
"timestamp = {0,number,#}, delta = {1,number,#}",
new Object[] { timestamp, delta }
);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson4;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.TaskManager;
/**
* A simple persistence example for the Project Darkstar Server.
*/
public class HelloPersistence2
implements AppListener, Serializable
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloPersistence2.class.getName());
 
/** The delay before the first run of the task. */
public static final int DELAY_MS = 5000;
 
/** The time to wait before repeating the task. */
public static final int PERIOD_MS = 500;
 
// implement AppListener
/**
* {@inheritDoc}
* <p>
* Creates a {@link TrivialTimedTask} and schedules its {@code run()}
* method to be called periodically.
* <p>
* Since SGS tasks are persistent, the scheduling only needs to
* be done the first time the application is started. When the
* server is killed and restarted, the scheduled timer task will
* continue ticking.
* <p>
* Runs the task {@value #DELAY_MS} ms from now,
* repeating every {@value #PERIOD_MS} ms.
*/
public void initialize(Properties props) {
TrivialTimedTask task = new TrivialTimedTask();
logger.log(Level.INFO, "Created task: {0}", task);
TaskManager taskManager = AppContext.getTaskManager();
taskManager.schedulePeriodicTask(task, DELAY_MS, PERIOD_MS);
}
/**
* {@inheritDoc}
* <p>
* Prevents client logins by returning {@code null}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
return null;
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson4;
import com.sun.sgs.app.AppContext;
import java.io.Serializable;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.ManagedObject;
import com.sun.sgs.app.Task;
/**
* A simple repeating Task that tracks and prints the time since it was
* last run.
*/
public class TrivialTimedTask
implements Serializable, // for persistence, as required by          // ManagedObject.
ManagedObject, // to let the SGS manage our persistence.
Task // to schedule future calls to our run() method.
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(TrivialTimedTask.class.getName());
 
/** The timestamp when this task was last run. */
private long lastTimestamp = System.currentTimeMillis();
 
// implement Task
/**
* {@inheritDoc}
* <p>
* Each time this {@code Task} is run, logs the current timestamp and
* the delta from the timestamp of the previous run.
*/
public void run() throws Exception {
// We will be modifying this object.
AppContext.getDataManager().markForUpdate(this);
long timestamp = System.currentTimeMillis();
long delta = timestamp - lastTimestamp;
 
// Update the field holding the most recent timestamp.
lastTimestamp = timestamp;
logger.log(Level.INFO,
"timestamp = {0,number,#}, delta = {1,number,#}",
new Object[] { timestamp, delta }
);
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.sun.sgs.tutorial.server.lesson4;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.DataManager;
import com.sun.sgs.app.ManagedReference;
import com.sun.sgs.app.Task;
import com.sun.sgs.app.TaskManager;
/**
* A simple persistence example for the Project Darkstar Server.
*/
public class HelloPersistence3
implements AppListener, Serializable, Task
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloPersistence3.class.getName());
 
/** The delay before the first run of the task. */
public static final int DELAY_MS = 5000;
 
/** The time to wait before repeating the task. */
public static final int PERIOD_MS = 500;
 
/** A reference to our subtask, a {@link TrivialTimedTask}. */
private ManagedReference<TrivialTimedTask> subTaskRef = null;
 
/**
* Gets the subtask this task delegates to. Dereferences a
* {@link ManagedReference} in this object that holds the subtask.
* <p>
* This null-check idiom is common when getting a ManagedReference.
*
* @return the subtask this task delegates to, or null if none is set
*/
public TrivialTimedTask getSubTask() {
if (subTaskRef == null) {
return null;
}
return subTaskRef.get();
}
/**
* Sets the subtask this task delegates to. Stores the subtask
* as a {@link ManagedReference} in this object.
* <p>
* This null-check idiom is common when setting a ManagedReference,
* since {@link DataManager#createReference createReference} does
* not accept null parameters.
*
* @param subTask the subtask this task should delegate to,
* or null to clear the subtask
*/
public void setSubTask(TrivialTimedTask subTask) {
if (subTask == null) {
subTaskRef = null;
return;
}
DataManager dataManager = AppContext.getDataManager();
subTaskRef = dataManager.createReference(subTask);
}
 
// implement AppListener
/**
* {@inheritDoc}
* <p>
* Schedules the {@code run()} method of this object to be called
* periodically.
* <p>
* Since SGS tasks are persistent, the scheduling only needs to
* be done the first time the application is started. When the
* server is killed and restarted, the scheduled timer task will
* continue ticking.
* <p>
* Runs the task {@value #DELAY_MS} ms from now,
* repeating every {@value #PERIOD_MS} ms.
*/
public void initialize(Properties props) {
// Hold onto the task (as a managed reference)
setSubTask(new TrivialTimedTask());
TaskManager taskManager = AppContext.getTaskManager();
taskManager.schedulePeriodicTask(this, DELAY_MS, PERIOD_MS);
}
/**
* {@inheritDoc}
* <p>
* Prevents client logins by returning {@code null}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
return null;
}
 
// implement Task
/**
* {@inheritDoc}
* <p>
* Calls the run() method of the subtask set on this object.
*/
public void run() throws Exception {
// Get the subTask (from the ManagedReference that holds it)
TrivialTimedTask subTask = getSubTask();
if (subTask == null) {
logger.log(Level.WARNING, "subTask is null");
return;
}
 
// Delegate to the subTask's run() method
subTask.run();
}
}

/*
* Copyright 2007-2009 Sun Microsystems, Inc.
*
* This file is part of Project Darkstar Server.
*
* Project Darkstar Server is free software: you can redistribute it
* and/or modify it under the terms of the GNU General Public License
* version 2 as published by the Free Software Foundation and
* distributed hereunder to you.
*
* Project Darkstar Server is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
package com.sun.sgs.tutorial.server.lesson3;
import java.io.Serializable;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sun.sgs.app.AppContext;
import com.sun.sgs.app.AppListener;
import com.sun.sgs.app.ClientSession;
import com.sun.sgs.app.ClientSessionListener;
import com.sun.sgs.app.Task;
import com.sun.sgs.app.TaskManager;
/**
* A simple timed-task example for the Project Darkstar Server.
* It uses the {@link TaskManager} to schedule itself as a periodic task
* that logs the current timestamp on each execution.
*/
public class HelloTimer
implements AppListener, // to get called during application startup.
Serializable, // since all AppListeners are ManagedObjects.
Task // to schedule future calls to our run() method.
{
/** The version of the serialized form of this class. */
private static final long serialVersionUID = 1L;
 
/** The {@link Logger} for this class. */
private static final Logger logger =
Logger.getLogger(HelloTimer.class.getName());
 
/** The delay before the first run of the task. */
public static final int DELAY_MS = 5000;
 
/** The time to wait before repeating the task. */
public static final int PERIOD_MS = 500;
 
// implement AppListener
/**
* {@inheritDoc}
*
 
* Schedules the {@code run()} method to be called periodically.
* Since SGS tasks are persistent, the scheduling only needs to
* be done the first time the application is started. When the
* server is killed and restarted, the scheduled timer task will
* continue ticking.
*
 
* Runs the task {@value #DELAY_MS} ms from now,
* repeating every {@value #PERIOD_MS} ms.
*/
public void initialize(Properties props) {
TaskManager taskManager = AppContext.getTaskManager();
taskManager.schedulePeriodicTask(this, DELAY_MS, PERIOD_MS);
}
/**
* {@inheritDoc}
*
 
* Prevents client logins by returning {@code null}.
*/
public ClientSessionListener loggedIn(ClientSession session) {
return null;
}
// implement Task
/**
* {@inheritDoc}
*
 
* Logs the current timestamp whenever this {@code Task} gets run.
*/
public void run() throws Exception {
logger.log(Level.INFO,
"HelloTimer task: running at timestamp {0,number,#}",
System.currentTimeMillis());
}
}