Ich habe da noch einige viele datein zu.
Ein PHP Ordner mit PHP skripten
Ein FLA Ordner mit den chat
Und halt den Java ordner mit der .java datei
http://www.fotos-hochladen.net/uploads/unbenanntfbh8xkrca4.png
Das sind die Ordner die ich alle habe für den chat.
Und das hier steht in der Application.java :
package chat;
import org.red5.server.adapter.ApplicationAdapter;
import org.red5.server.api.IConnection;
import org.red5.server.api.IClient;
import org.red5.server.api.IScope;
import org.red5.server.api.Red5;
import org.red5.server.api.service.IServiceCapableConnection;
import org.red5.server.api.so.ISharedObject;
import org.red5.server.api.ScopeUtils;
import org.red5.server.api.so.ISharedObjectService;
import org.red5.server.api.*;
import org.red5.server.api.scheduling.*;
import org.red5.samples.components.ClientManager;
import org.red5.server.api.service.ServiceUtils;
import org.red5.server.api.service.*;
import org.red5.server.api.service.IPendingServiceCallback;
//
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import java.util.*;
import java.util.HashMap;
//
//
public class Application extends ApplicationAdapter{
public HashMap<String,User> users = new HashMap<String,User>();
public class User {
public String id = null;
public String pseudo = null;
public String webcam = null;
public String role = null;
public String sex = null;
public String onlineStatus = null;
public String room=null;
public String world=null;
public String isWatching=null;
public String hasWebcam=null;
public User (String id,String pseudo,String webcam, String role,String sex,String onlineStatus,String room,String world,String isWatching,String hasWebcam) {
this.id = id;
this.pseudo = pseudo;
this.webcam = webcam;
this.role = role;
this.sex = sex;
this.onlineStatus = "true";
this.room = room;
this.world = world;
this.isWatching = "false";
this.world = world;
}
}
// ici le callback ! ! !
/*if (conn instanceof IServiceCapableConnection) {
IServiceCapableConnection sc = (IServiceCapableConnection) conn;
sc.invoke("the_method", new Object[]{"One", 1}, new MyCallback());
}
sc.invoke("echo", new Object[]{"Hello world!"},
new IPendingServiceCallback() {
public void resultReceived(IPendingServiceCall call) {
System.err.println("Received: " + call.getResult());
}
});
*/
class MyCallback implements IPendingServiceCallback {
public void resultReceived(IPendingServiceCall call) {
// Do something with "call.getResult()"
}
}
//private ClientManager2 clientMgr = new ClientManager2("users_so","online",true);
private ClientManager clientMgr = new ClientManager("users_so",true);
private static final Log log = LogFactory.getLog( Application.class );
//ISharedObject users_so;
//= getSharedObject(scope);
//ArrayList listeUsers = new ArrayList();
//ArrayList listeObjectUsers = new ArrayList();
/** Manager for the clients. */
public void disconnectUser(String connectionID)
{ //code to inform other clients that this client with this connection ID has left below...
}
/*
* (non-Javadoc)
* @see org.red5.server.adapter.ApplicationAdapter#connect(org.red5.server.api.IConnection, org.red5.server.api.IScope, java.lang.Object[])
* connect an users with 7 parameters: username,webcam,onlineStatus, role, room, world
*/
public boolean connect(IConnection conn, IScope scope, Object[] params) {
log.info("connect IConnection nombre params="+ params.length);
// Check if the user passed valid parameters.
//params = pseudo onlineStatus role sexe room world
if (params.length==1) {
log.info("getNumberUsersConnected");
((IServiceCapableConnection) conn).invoke("getNumberUsersConnected", new Object[]{users.size()});
//rejectClient("getNumberUsersConnected !.");
conn.close();
return false;
}
if (params == null || params.length != 7) {
log.info("Client must pass 7 params !");
rejectClient("Client must pass 7 params !.");
return false;
}
String id = conn.getClient().getId();
String pseudo = params[0].toString();
String webcam = params[1].toString();
String onlineStatus = params[2].toString();
String role=params[3].toString();
String sex = params[4].toString();
String room = params[5].toString();
String world=params[6].toString();
String isWatching="false";
String hasWebcam="true";
// test if username is already used
if (users.containsKey(pseudo)) {
rejectClient("Error: pseudo "+pseudo+" already used.");
return false;
}
// Call original method of parent class.
if (!super.connect(conn, scope, params)) {
return false;
}
log.info("ici2");
users.put(pseudo,new User(id,pseudo,webcam, role,sex,onlineStatus,room,world,isWatching,hasWebcam));
log.info("ici3");
log.info("connected as :"+pseudo+"webcam="+webcam+" status="+onlineStatus+"role="+role+"sexe="+sex+"room="+room+"world="+world);
clientMgr.addClient(scope, pseudo, id);
ServiceUtils.invokeOnAllConnections (scope, "joinuser", new Object[] {id,pseudo,webcam, onlineStatus,role,sex,room,world} );
return true;
}
/*
* (non-Javadoc)
* @see org.red5.server.adapter.ApplicationAdapter#disconnect(org.red5.server.api.IConnection, org.red5.server.api.IScope)
* disconnect an user form the chat and notify all others users
*/
public void disconnect(IConnection conn, IScope scope) {
// Get the previously stored username.
String id = conn.getClient().getId();
// Unregister user.
String pseudo = clientMgr.removeClient(scope, id);
User user=users.get(pseudo);
users.remove(pseudo);
log.info("removeuser invoked id:"+user.id+" pseudo="+user.pseudo+"sexe="+user.sex);
ServiceUtils.invokeOnAllConnections (scope, "removeuser", new Object[] {user.id,user.pseudo,user.room,user.world} );
super.disconnect(conn, scope);
}
public boolean appJoin(IClient client, IScope scope) {
log.info("Client joined app " + client.getId());
// If you need the connecion object you can access it via.
//IConnection conn = Red5.getConnectionLocal();
return true;
}
public void send_to_all_iterate() {
IConnection current = Red5.getConnectionLocal();
Iterator<IConnection> it = scope.getConnections();
while (it.hasNext()) {
IConnection conn = it.next();
if (conn.equals(current)) continue;
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("someClientMethod", new Object[]{"Hello World"});
log.debug("sending notification to "+conn);
}
}
}
/*
* get all the already connected users
*/
public HashMap<String,User> getUserList() {
/*IConnection conn = Red5.getConnectionLocal();
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("receive_private", new Object[]{"zaza"});
log.info("getUserList"+conn.getClient().getId());
}*/
//listeObjectUsers.toString()
log.info("getUserList called");
return users;
}
/*
* send a public message msg from from_pseudo to ALL users
*/
public void send_public(String from_pseudo, String msg) {
//Iterator<IConnection> it = scope.getConnections();
log.info("send_public from_pseudo"+from_pseudo+" msg:"+msg);
ServiceUtils.invokeOnAllConnections (scope, "receivePublicMsg", new Object[] {from_pseudo,msg} );
}
/*
* start Talk invoked on all users by whoTalks
*/
public void startTalk(String whoTalks) {
log.info("startTalk: "+whoTalks);
ServiceUtils.invokeOnAllConnections (scope, "talkStarted", new Object[] {whoTalks} );
}
/*
* stop Talk invoked on all users by whoTalks
*/
public void stopTalk(String whoTalks) {
log.info("stopTalk: "+whoTalks);
ServiceUtils.invokeOnAllConnections (scope, "talkEnded", new Object[] {whoTalks} );
}
/*
* gett the number of connected users to the chat
*/
public int getNumberUsersConnected(){
return users.size();
}
/*
* start requestHand invoked on all users by whoRequests
*/
public void requestHand(String whoRequests) {
log.info("send_public from_pseudo"+whoRequests);
ServiceUtils.invokeOnAllConnections (scope, "handRequested", new Object[] {whoRequests} );
}
/*
* send a privateMessage msg from fromPseudo to sendToId user
*/
public void send_private_id(String sendToId,String fromPseudo, String msg) {
//IConnection current = Red5.getConnectionLocal();
Iterator<IConnection> it = scope.getConnections();
log.debug("send_private to "+sendToId+" "+msg);
//String uid = scope.getClient().getId();
while (it.hasNext()) {
IConnection conn = it.next();
String id=conn.getClient().getId();
if (!(sendToId.equals(id))) continue;
log.info("receive_private "+sendToId+" "+msg);
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("receive_private", new Object[]{msg});
log.info("received_private "+sendToId+" "+msg);
return;
}
}
}
/*
* who is wathing who function
*/
public void watches(String UserId) {
IConnection conn2 = Red5.getConnectionLocal();
String uid = conn2.getClient().getId();
Iterator<IConnection> it = scope.getConnections();
log.debug("watches "+UserId);
while (it.hasNext()) {
IConnection conn = it.next();
String id=conn.getClient().getId();
if (!(UserId.equals(id))) continue;
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("watches", new Object[]{uid});
log.info(uid+" is watching "+UserId);
return;
}
}
}
/*
* ban the user _id
*/
public void ban(String _id) {
Iterator<IConnection> it = scope.getConnections();
//log.debug("ban called: "+_id);
while (it.hasNext()) {
IConnection conn = it.next();
String id=conn.getClient().getId();
if (!(_id.equals(id))) continue;
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("IhaveBeenBanned", new Object[]{_id});
log.info("ban "+_id);
}
}
}
/*
* kick the user _id
*/
public void kick(String _id) {
Iterator<IConnection> it = scope.getConnections();
//log.debug("kick called: "+_id);
while (it.hasNext()) {
IConnection conn = it.next();
String id=conn.getClient().getId();
if (!(_id.equals(id))) continue;
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("IhaveBeenKicked", new Object[]{_id});
log.info("kick "+_id);
}
}
}
/*
* send a private message msg from user fromPseudo to detsination user DestinationID
*/
public void send_private(String fromPseudo, String DestinationID,String msg) {
//IConnection current = Red5.getConnectionLocal();
Iterator<IConnection> it = scope.getConnections();
log.debug("send_private to "+DestinationID+" "+msg);
//String uid = scope.getClient().getId();
while (it.hasNext()) {
IConnection conn = it.next();
String id=conn.getClient().getId();
log.debug("id="+id+ " senTO="+DestinationID);
//if (sendTo.equals(id)) log.info("PAREIL"); else log.info("differents");
if (!(DestinationID.equals(id))) continue;
log.info("receive_private "+DestinationID+" "+msg);
if (conn instanceof IServiceCapableConnection) {
((IServiceCapableConnection) conn).invoke("receivePrivateMsg", new Object[]{fromPseudo, msg});
log.info("received_private "+DestinationID+" "+msg);
}
}
}
/*
* change the status of the webcam: can be "on" or "off"
*/
public void change_webcam(String webcam) {
//
IScope appScope = Red5.getConnectionLocal().getScope();
IConnection conn = Red5.getConnectionLocal();
String uid = conn.getClient().getId();
log.debug("change_webcam called form id:"+uid+" :"+webcam);
ServiceUtils.invokeOnAllConnections (appScope, "change_webcam", new Object[]{uid,webcam} );
}
/*
* change the status of the user to "status"
*/
//
public void changeProfil(String webcam,String role, String onlineStatus) {
//
IScope appScope = Red5.getConnectionLocal().getScope();
IConnection conn = Red5.getConnectionLocal();
String _id = conn.getClient().getId();
log.debug("changeProfil called form id:"+_id+" :"+webcam);
ServiceUtils.invokeOnAllConnections (appScope, "changeProfil", new Object[]{_id,webcam,role,onlineStatus} );
// return (new Object[]{uid,status});
}
public Double add(Double a, Double b){
return a + b;
}
public Boolean appStart() {
//users_so = SharedObject.get("users_so", false);
createSharedObject(Red5.getConnectionLocal().getScope(), "users_so", false);
log.debug("application START!");
return true;
}
public boolean roomStart(IScope room) {
log.info( "Red5First.room start " + room);
if (!super.roomStart(room))
return false;
//createSharedObject(room, "sampleSO", true);
//ISharedObject so = getSharedObject(room, "sampleSO");
// Now you could do something with the shared object...
return true;
}
public String whoami() {
IConnection conn = Red5.getConnectionLocal();
IClient client = conn.getClient();
IScope scope = conn.getScope();
return client.getId();
// ...
}
public void callclient() {
log.info("callclient called");
IConnection conn = Red5.getConnectionLocal();
if (conn instanceof IServiceCapableConnection) {
IServiceCapableConnection sc = (IServiceCapableConnection) conn;
log.info("flashmethod called");
sc.invoke("flashmethod", new Object[]{"One", 1});
}
}
public boolean appConnect( IConnection conn , Object[] params )
{
//String id=conn.getClient().getId();
//String username=(String)params[1];
//String password=(String)params[2];
//String sexe=(String)params[3];
//String status=(String)params[4];
// cherche si user déjà dans la liste
//Cuser user=new Cuser(id,username,password,sexe,status);
/*if (this.list[UserName]) {
application.rejectConnection(newClient, {msg:"Nom déjà utilisé, essayez de nouveau."});
trace("### name taken");
return;
}
*/
log.info( "appConnect " + conn.getClient().getId() );
//boolean accept = (Boolean)params[0];
//String user=(String)params[1];
// if ( !accept ) rejectClient( "you passed false..." );
return true;
}
public void appDisconnect( IConnection conn){
log.info( "Red5First.appDisconnect " + conn.getClient().getId() );
// IScope appScope = Red5.getConnectionLocal().getScope();
// ServiceUtils.invokeOnAllConnections (appScope, "removeuser", new Object[] { "zaza" } );
}
public void appStop() {
log.info( "Red5First.appStop" );
}
}
