[Sql Server] - Notification de mise à jour

Version imprimable

29/09/2009, 14h28
Anto03

[Sql Server] - Notification de mise à jour

Bonjour à tous,

Dans mon appli silverlight je dois vérifier qu'un champ d'une table n'a pas été modifié. Pour se faire j'ai fait un petit timer qui vérifie cela toute les secondes.

Ma question, vous la voyez venir, est simple : plutôt que de faire une requête toute les secondes peut on notifier la modification au client silverlight ??

Merci d'avance pour votre aide.
29/09/2009, 14h47
Invité

Citation:

Envoyé par Anto03

Bonjour à tous,

Dans mon appli silverlight je dois vérifier qu'un champ d'une table n'a pas été modifié. Pour se faire j'ai fait un petit timer qui vérifie cela toute les secondes.

Peut on savoir pourquoi cette vérification :?:?:?
29/09/2009, 14h55
Anto03

Oui bien sûr. Il s'agit d'un petit jeu en silverlight qui se joue joueur contre joueur et tour par tour (comme une partie d'échec).

Donc le joueur 1 joue, il met à jour un champ dans une table pour dire qu'il a fini son tour. Ensuite le joueur 2 doit savoir que c'est à son tour de jouer, d'ou mon timer.

L'idée du timer ne me plait pas vraiment, c'est pour ça que je pose la question ;)
29/09/2009, 15h20
Invité

Je pense qu'il existe d'autre méthodes plus appropriées que ta méthode qui n'est pas assez élégante. Ben il va falloir que je fouille dans mes TP il me semble que j'ai une fois résolu ce genre de truc.
Je te fais signe d'ici peu ..:ccool:
29/09/2009, 15h33
Louis-Guillaume Morand

un serveur pardi c'est fait pour.
SL => Serveur => SL

chaque client communique au serveur qui communique avec l'autre client. C'est comme cela que marchent tous les jeux d'Internet. Un Serveur SQL ne fait pas de "push" à ma connaissance
29/09/2009, 16h09
Anto03

En effet, l'idée du serveur m'a traversé l'esprit. Mais même souci, ce sera le serveur qui fera le test toute les secondes et qui notifiera la modification à l'application silverlight !

A la limite, c'est son boulot, mais j'avais peur que ce soit trop lourd si ya 100 joueurs par exemple ça fait 100 requêtes par seconde....

Dans ce cas là, techniquement ça marche comment ? :mrgreen:
29/09/2009, 16h19
Louis-Guillaume Morand

Citation:

Envoyé par Anto03

En effet, l'idée du serveur m'a traversé l'esprit. Mais même souci, ce sera le serveur qui fera le test toute les secondes et qui notifiera la modification à l'application silverlight !

A la limite, c'est son boulot, mais j'avais peur que ce soit trop lourd si ya 100 joueurs par exemple ça fait 100 requêtes par seconde....

Dans ce cas là, techniquement ça marche comment ? :mrgreen:

pas du tout. le serveur ne fait pas de test, il écoute. c'est ton client qui appelle le serveur pour dire "j'ai joué ceci". le serveur vérifie que c'était bien à ce joueur de jouer, il entre le choix du mec en base puis contacte l'autre client (avec qui il a une connexion constante puisque c'est un serveur) et lui dit, à toi de jouer, ton ennemi a joué ceci. dans le même temps, il envoie au joueur qui a joué une commande pour dire "c'est au tour de l'autre, merci d'attendre".

Après, je connais pas les détails de ton jeu, car un tour par tour peut se faire dans la durée (plusieurs jours) mais il faut penser connexion avec le serveur et un principe de "push" dans les deux sens, pas de timer ou quoi que ce soit. juste des listener
29/09/2009, 16h31
Anto03

Merci Louis-Guillaume pour ces infos ! :ccool:

C'est en effet exactement ce qu'il me faut ! Une partie se déroulera en 2 min en moyenne avec des tours de 10 secondes maximum. Au bout de 10 secondes si le joueur n'a pas joué on passe au joueur suivant.

Si je suis ton raisonnement pour mettre en place ça coté serveur, il faut que le serveur enregistre l'heure lorsque il donne la main au joueur 1 et si au bout de 10 secondes il reçoit aucune réponse il passe la main, c'est ça ? Donc là, Timer ? lol :aie:

Bon j'ai la théorie, mais techniquement ou puis-je trouver des ressources ou exemple ? h2s84 tu as un TP sur ce sujet ??
29/09/2009, 16h43
Louis-Guillaume Morand

Citation:

Envoyé par Anto03

Merci Louis-Guillaume pour ces infos ! :ccool:

C'est en effet exactement ce qu'il me faut ! Une partie se déroulera en 2 min en moyenne avec des tours de 10 secondes maximum. Au bout de 10 secondes si le joueur n'a pas joué on passe au joueur suivant.

Si je suis ton raisonnement pour mettre en place ça coté serveur, il faut que le serveur enregistre l'heure lorsque il donne la main au joueur 1 et si au bout de 10 secondes il reçoit aucune réponse il passe la main, c'est ça ? Donc là, Timer ? lol :aie:

Bon j'ai la théorie, mais techniquement ou puis-je trouver des ressources ou exemple ? h2s84 tu as un TP sur ce sujet ??

alors oui et non. J'ai pas trop le temps de réfléchir à ton problème, mais non pas besoin de timer. Pour moi, la vérification serveur se fait en faisant une comparaison avec leur de la dernière action de l'autre joueur. ca coute "une soustraction" plutôt qu'un timer qui tourne constamment.

ou alors, tu mets un timer chez le client.

pour les ressources, cherche les articles qui parlent de chat en silverlight, c'est le meme principe de communication. après, tu mets ce que tu veux dans le message, des commandes ou autre.
29/09/2009, 17h36
Skyounet
Tu as 2 solutions :
- Un service wcf en polling duplex
- Un serveur de socket
Selon la charge que tu estimes il faut choisir.
Je crois que la limite d'un WCF en polling duplex c'est 10 clients.

Pour un serveur de socket c'est illimité.
Oublie pas de prendre en compte le fait que plusieurs parties peuvent être joué en même temps.

M'est avis que tu vas terminer sur un serveur de socket comme moi j'ai opté pour mon jeu.
29/09/2009, 17h43
Skyounet

Ah et pour ton système de 10 secondes sans jouer.
Dès que le serveur dit à un client : c'est ton tour.
Tu lances un timer de 10sec.
Si le Tick s'exécute tu envoies au serveur la requête qui dit : le tour est fini, signale au joueur suivant que c'est à lui.
Si le joueur joue avant, tu stop ton timer.
29/09/2009, 20h42
Thomas Lebrun

Citation:

Envoyé par Anto03

Bonjour à tous,

Dans mon appli silverlight je dois vérifier qu'un champ d'une table n'a pas été modifié. Pour se faire j'ai fait un petit timer qui vérifie cela toute les secondes.

Ma question, vous la voyez venir, est simple : plutôt que de faire une requête toute les secondes peut on notifier la modification au client silverlight ??

Merci d'avance pour votre aide.

Marrant, cela me fait penser à ca: http://msdn.microsoft.com/en-us/library/ms175110.aspx
30/09/2009, 08h59
Anto03

Merci pour toutes vos réponses !

@Skyounet : Le serveur de socket me paraît en effet le plus adapté. Pour les 10 secondes je voyais bien les choses comme ça aussi :). Aurais tu un lien, une documentation technique pour faire un serveur de socket sous silverlight / C# ?

@Thomas Lebrun : en effet, j'avais déjà trouvé de la documentation à ce sujet. Avec WCF : http://msdn.microsoft.com/en-us/libr...1(BTS.10).aspx
Et la notification avec Oracle : http://www.codeproject.com/KB/WCF/WC...ification.aspx mais je ne sais pas si c'est facilement applicable sous sql Serveur.

De toute façon, si j'opte pour le système de serveur de Louis-Guillaume et Skyounet je n'ai plus besoin de ce système !
30/09/2009, 09h06
Thomas Lebrun

Citation:

Envoyé par Anto03

@Thomas Lebrun : en effet, j'avais déjà trouvé de la documentation à ce sujet. Avec WCF : http://msdn.microsoft.com/en-us/libr...1(BTS.10).aspx
Et la notification avec Oracle : http://www.codeproject.com/KB/WCF/WC...ification.aspx mais je ne sais pas si c'est facilement applicable sous sql Serveur.

Le lien http://msdn.microsoft.com/en-us/libr...1(BTS.10).aspx te montre comment faire avec SQL Server donc pas de pb ;)
30/09/2009, 12h25
Invité

Mon TP, je ne l'ai pas encore trouvé mais comme parmi les solutions proposées par Skyounet j'utilisais les sockets et mon client était en Winform.
Bref je crois que tu devrait te pencher sur les sockets non ?:ccool:
01/10/2009, 11h01
Anto03

Désolé pour le retard de ma réponse... Donc oui évidemment je me suis lancé dans les sockets !

Voici les quelques liens que j'ai trouvé pour ceux que ça intéresse :

http://weblogs.asp.net/dwahlin/archi...ts-part-i.aspx
http://techblogging.wordpress.com/20...n-silverlight/

Si vous avez d'autres ressources je suis preneur ! :ccool:

Merci beaucoup pour votre aide à tous en tout cas !!
01/10/2009, 13h44
Skyounet

Ben je peux te montrer mon code si tu veux :aie:
01/10/2009, 16h43
Anto03

Rooh oui je veux bien ! Grand fou va ! :mouarf:

Plaisanterie mis à part, oui je serais très curieux de voir ça surtout que ce que tu as fait ce rapproche bcp de ce que je veux faire si j'ai tout compris ?

Comment on procède pour l'envoie ?

Alors déjà il te faut 2 serveurs. Un qui va être utiliser pour le Clientaccesspolicy et un autre qui sera ton serveur à toi.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.IO;
using System.Net;
 
namespace CrossPolicyServer
{
    // Encapsulate and manage state for a single connection from a client
    class PolicyConnection
    {
        private Socket mConnection;
 
        // buffer to receive the request from the client
        private byte[] mBuffer;
        private int mReceived;
 
        // the policy to return to the client
        private byte[] mPolicy;
 
        // the request that we're expecting from the client
        private static string policyRequestString = "<policy-file-request/>";
 
        public PolicyConnection(Socket client, byte[] policy)
        {
            mConnection = client;
            mPolicy = policy;
 
            mBuffer = new byte[policyRequestString.Length];
            mReceived = 0;
 
            try
            {
                // receive the request from the client
                mConnection.BeginReceive(mBuffer, 0, policyRequestString.Length, SocketFlags.None, new AsyncCallback(OnReceive), null);
            }
            catch (SocketException)
            {
                mConnection.Close();
            }
        }
 
        // Called when we receive data from the client
        private void OnReceive(IAsyncResult res)
        {
            try
            {
                mReceived += mConnection.EndReceive(res);
 
                // if we haven't gotten enough for a full request yet, receive again
                if (mReceived < policyRequestString.Length)
                {
                    mConnection.BeginReceive(mBuffer, mReceived, policyRequestString.Length - mReceived, SocketFlags.None, new AsyncCallback(OnReceive), null);
                    return;
                }
 
                // make sure the request is valid
                string request = System.Text.Encoding.UTF8.GetString(mBuffer, 0, mReceived);
                if (StringComparer.InvariantCultureIgnoreCase.Compare(request, policyRequestString) != 0)
                {
                    mConnection.Close();
                    return;
                }
 
                // send the policy
                mConnection.BeginSend(mPolicy, 0, mPolicy.Length, SocketFlags.None, new AsyncCallback(OnSend), null);
            }
            catch (SocketException)
            {
                mConnection.Close();
            }
        }
 
        // called after sending the policy to the client; close the connection.
        public void OnSend(IAsyncResult res)
        {
            try
            {
                mConnection.EndSend(res);
            }
            finally
            {
                mConnection.Close();
            }
        }
    }
 
    // Listens for connections on port 943 and dispatches requests to a PolicyConnection
    class PolicyServer
    {
        private Socket mListener;
        private byte[] mPolicy;
 
        // pass in the path of an XML file containing the socket policy
        public PolicyServer(string policyFile)
        {
            // Load the policy file
            FileStream policyStream = new FileStream(policyFile, FileMode.Open);
 
            mPolicy = new byte[policyStream.Length];
            policyStream.Read(mPolicy, 0, mPolicy.Length);
 
            policyStream.Close();
 
 
            // Create the Listening Socket
            mListener = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);
 
            // Put the socket into dual mode to allow a single socket 
            // to accept both IPv4 and IPv6 connections
            // Otherwise, server needs to listen on two sockets,
            // one for IPv4 and one for IPv6
            // NOTE: dual-mode sockets are supported on Vista and later
            mListener.SetSocketOption(SocketOptionLevel.IPv6, (SocketOptionName)27, 0);
 
            mListener.Bind(new IPEndPoint(IPAddress.IPv6Any, 943));
            mListener.Listen(10);
 
            mListener.BeginAccept(new AsyncCallback(OnConnection), null);
        }
 
        // Called when we receive a connection from a client
        public void OnConnection(IAsyncResult res)
        {
            Socket client = null;
 
            try
            {
                client = mListener.EndAccept(res);
            }
            catch (SocketException)
            {
                return;
            }
 
            // handle this policy request with a PolicyConnection
            PolicyConnection pc = new PolicyConnection(client, mPolicy);
 
            // look for more connections
            mListener.BeginAccept(new AsyncCallback(OnConnection), null);
        }
 
        public void Close()
        {
            mListener.Close();
        }
    }
 
 
 
    public class Program
    {
        static void Main(string[] args)
        {
            PolicyServer ps = new PolicyServer("clientaccesspolicy.xml");
            System.Threading.Thread.Sleep(System.Threading.Timeout.Infinite);
        }
 
    }
}

Ensuite là fichier xml qui va bien :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
<?xml version="1.0" encoding ="utf-8"?>
<access-policy>
  <cross-domain-access>
    <policy>
      <allow-from>
        <domain uri="*" />
      </allow-from>
      <grant-to>
        <socket-resource port="4530" protocol="tcp" />
      </grant-to>
    </policy>
  </cross-domain-access>
</access-policy>

J'utilise donc le port 4530 pour mon serveur pour mon jeu.

Et en gros pour le serveur ça donne ça

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
class Server
{
    public void Initialize()
    {
        Console.WriteLine("Starting Socket listener...");
        WaitingForClients();
        //mThreadConnection = new Thread(new ThreadStart(WaitingForClients));            
    }
 
    private void WaitingForClients()
    {
        mListener = new TcpListener(IPAddress.Parse("127.0.0.1"), 4530);
 
        mListener.Start();
 
        while (true)
        {
            Socket client = mListener.AcceptSocket();
 
            Console.WriteLine(string.Format("Starting Socket Listener for client {0}", client.RemoteEndPoint.ToString()));
 
            int id = ReadId(client);
 
            WaitForReceive(client);
        }
    }
 
    private short ReadId(Socket client)
    {
        using (BinaryReader reader = new BinaryReader(new NetworkStream(client)))
        {
            reader.ReadInt16(); /* swap command */
            return reader.ReadInt16();
        }
    }
 
    private void OnAsyncSocketOperationComplete(object sender, SocketAsyncEventArgs e)
    {
        if (e.LastOperation == SocketAsyncOperation.Receive)
        {
            DataReceived(e);
        }
    }
 
    private void WaitForReceive(Socket socket)
    {
        SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
 
        socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(OnAsyncSocketOperationComplete);
        socketEventArg.RemoteEndPoint = socket.RemoteEndPoint;
        socketEventArg.UserToken = socket;
        socketEventArg.SetBuffer(new byte[256], 0, 256);
 
        socket.ReceiveAsync(socketEventArg);
    }
 
    private void DataReceived(SocketAsyncEventArgs e)
    {
        if (e.BytesTransferred == 0)
        {
            // player disconnected
            return;
        }
 
        using (MemoryStream stream = new MemoryStream(e.Buffer, e.Offset, e.BytesTransferred))
        {
            using (BinaryReader reader = new BinaryReader(stream))
            {
                short command = reader.ReadInt16();
 
                switch ((Command)command)
                {
                    case ...
 
                    default:
                        break;
                }
            }
        }
 
        WaitForReceive(e.UserToken as Socket);
    }
 
    private void SendCommand(Socket socket, params short[] args)
    {
        SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
 
        socketEventArg.RemoteEndPoint = socket.RemoteEndPoint;
        socketEventArg.UserToken = socket;
 
        // juste une méthode pour convertir un tableau de short en tableau de byte
        byte[] bytes = Utils.Convert(args);
 
        socketEventArg.SetBuffer(bytes, 0, bytes.Length);
 
        socket.Send(bytes);
    }
 
}

Et dans mon serveur j'ai une liste de Player (mais j'ai pas mis dans le code là) avec Player qui est :

Code:

1
2
3
4
5
class Player
{
    public Players PlayerEntity { get; set; }
    public Socket Socket { get; set; }
}

Players c'est une classe qui vient de ma bdd générée via Linq To Entities.

Ensuite chaque Players est relié à un GameInfo (aussi une table en bdd) pour gérer plusieurs jeux en même temps.

Donc un player parle au serveur avec comme format : commande arguments
arguments ça peut être par exemple : joueur provenance, joueur destination, case a attaquer
De l'autre côté selon la commande (un enum) je récupère les différents arguments. Quand le nombre d'argument est variables le format devient
commande nombre d'argument arguments.

De l'autre côté pour le joueur c'est la même principe si ce n'est qu'il faut se connecter au serveur d'abord.
Si tu as des problèmes pour cette partie je pourrais te montrer.

01/10/2009, 23h02
Invité

Comme j'ai pas trouvé mon TP et que je suis paresseux de te faire un p'tit exemple. En voivi un.
02/10/2009, 09h10
Anto03

Merci encore à tous les deux ! La vidéo est vraiment bien faite :ccool:.

Skyounet, merci pour ton code, il y a juste une chose qui m'échappe : pourquoi faire deux serveurs ??

Je connais le fameux fichier clientaccesspolicy.xml mais je ne comprend pas à quoi sert ce code ?

Ensuite niveau client, je veux bien que tu me donne juste l'exemple de réception des données si ça te dérange pas :aie:

Merci pour votre aide !
02/10/2009, 13h26
Skyounet

Ben en fait c'est écrit dans la doc.

Quand un client tente de se connecter à un serveur via des sockets il fait d'abord une requête sur le port 943 et demande le fichier clientaccesspolicy pour voir si il est autorisé à se connecter au port qu'il demande (4530 dans mon cas).

Donc en fait le premier serveur c'est celui qui répond à la requête de clientaccesspolicy. C'est un serveur générique pour tous les cas d'utilisation de sockets en Silverlight.