Først, la oss starte med våre egne arrangement. Vår manager vil bli brukt til å la prosjektet vet når gruppen er klar til å brukes (connectedToGroup hendelse), når vi er frakoblet, når en ny nabo har sluttet og når en melding er mottatt. Tydeligvis mange andre arrangementer kan legges til, men la oss holde det enkelt for nå, og du vil være i stand til å utvide det senere. Snarere enn å forlenge Flash er DynamicObject, velger jeg å bare ha to felt for lagring av tilleggsdata når hendelsen bærer detaljene i en mottatt melding.

Så det ga oss en enkel hendelse som heter netgroup.NetGroupEvent:
pakke netgroup {import flash.events.Event; public class NetGroupEvent strekker Hendelses {statisk offentlig konst innlegg: String = 'posting'; statisk offentlig konst CONNECTED_TO_GROUP: String = 'connectedToGroup'; statisk offentlig konst DISCONNECTED_FROM_GROUP: String = 'disconnectedFromGroup'; statisk offentlig konst NEIGHBOR_JOINED: String = 'neighborJoined'; offentlig Var melding: Object; offentlig Var emne: String; offentlig funksjon NetGroupEvent (type: String, bobler: Boolean = false, cancelable: Boolean = false) {super (type, bobler, cancelable); }}}

Neste enkelt trinn, vil vi sette opp en meldingsformat. En melding vil ha et emne, en avsender og en del data. Faget er nyttig for ruting mottatt melding i en reell søknad, vil dataene være en slags generisk objekt. Husk netGroup.post () metoden vi kort nevnt i trinn 2. Det tar et objekt som argument. Så vi vil ha noen serialisering metoder for å lage en VoNetMessage fra et objekt, og opprette et objekt fra en VoNetMessage eksempel. Dette serialisering metoden vil bli gjennomført ved en enkel getter metode, og vi vil legge til her litt salt.

Husker du peer to peer automatisk håndtere ruting av meldingene. Hvis en node får en melding det allerede har videresendt, vil den vurdere dette budskapet like gammel, og vil ikke sende den på nytt. Men hva vil skje når vår søknad vil sende små enkle varsling som en enkelt streng 'endOfVote' for å varsle kunder avstemningen er avsluttet. Hvis vi starter en ny stemme, så stopper det, er dette veldig enkelt budskap vil bli sendt en gang til. Nøyaktig samme innhold. Men vi må sørge for at de jevnaldrende er klar over dette er enda en ny melding. Den enkleste måten å sørge for at dette er å legge litt salt i vårt budskap, når seriefunksjon den før du sender den. I dette eksempelet bruker jeg en enkel tilfeldig tall, men du vil kanskje legge til et tidsstempel, eller begynne å lage noen unike meldinger IDer. Du er sjefen. Det viktigste er å være klar over denne fallgruven. Da er du opp til å håndtere det slik du foretrekker.

Her kommer vår netgroup.VoNetGroupMessage i sin enkleste form:
pakke netgroup {/** * VoNetGroupMessage er litt helper som tvinger faget /data /avsender * felt før du sender en generisk objekt over luften . * * /Public class VoNetGroupMessage strekker Object {public Var emne: String; offentlig Var data: Object; offentlig Var avsender: String; //Avsenderens nearID offentlig funksjon får objekt (): Object {var o: Object = {}; o.subject = forbehold; o.data = data; o.sender = avsender; o.salt = Math.random () * 99999; //Vi legge litt salt for å sørge for at vi ikke sende samme melding 2 ganger tilbake o; } Offentlig funksjon VoNetGroupMessage (message: Object = null) {if (melding == null) message = {}; Emne = message.subject; data = message.data; avsender = message.sender; }}}

For å sende en melding til gruppen, vil det være så enkelt som Instantiating en VoNetGroupMessage, fyller sine fag- og data egenskaper, deretter passerer sitt objekt getter i netGroup.post () -metoden. Når en melding vil bli mottatt fra gruppen, Instantiating det med objektet mottatt som konstruktør argument vil automatisk fylle eiendommene, klar til å bli lest, som dette:
Var melding: VoNetGroupMessage = new VoNetGroupMessage (objectReceived)

Lederen vil være "black box" som vår søknad vil samhandle med å kommunisere med jevnaldrende. Vi ønsker ikke at våre forretningslogikk må ta vare på hvordan nettverket kommunikasjon foregår, vi ønsker bare å sende og motta meldinger. Så la oss starte med å definere den offentlige API vi ønsker for vår manager:

Det vil sende hendelser om hva som skjer, derfor vil det strekker EventDispatcher

Det vil være enkelt å sette opp til bruke vår egen rtmpServer verdi, developerKey hvis nødvendig, applicationName og groupname. Du trenger ikke å redigere klassen til å bruke det til et annet program.

La oss se på dette i detaljer

Det vil forlenge EventDispatcher, og vil sende de hendelsene vi har utarbeidet i NetGroupEvent. Vi hadde hendelses meta-tags for å gjøre deres bruk enklere: Twitter /** * Hendelse sendt hver gang du mottar en melding. * /[Hendelses (name = "oppslaget", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt når netConnection og NetGroup tilkoblinger har vært * vellykket, og gruppen er klar til å brukes. * /[Hendelses (name = "connectedToGroup", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt netgruppen forbindelsen er lukket. * /[Hendelses (name = "disconnectedFromGroup", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt netgruppen forbindelsen er lukket. * /[Hendelses (name = "neighborJoined", type = "netgroup.NetGroupEvent")]

Det vil også ha noen offentlige bindbare egenskaper til å ta en titt på gruppen staten. Vær forsiktig, har jeg latt dem som offentlige eiendommer for å gjøre koden mindre og lett bind, men disse skal ikke holdes eksternt redigeres i en virkelig verden prosjekt. Twitter /* --------------------------------------------- --------------------- * //* --- Nyttige offentlige eiendommer for forvaltning av konsernet --- * //* -------- -------------------------------------------------- -------- * /statisk offentlig konst STATE_DISCONNECTED: String = 'koblet'; statisk offentlig konst STATE_CONNECTING: String = 'koble'; statisk offentlig konst STATE_CONNECTED: String = "koblet"; private Var _neighborCount: int [bind (event = 'propertyChange')] /** neighborCount er en offentlig eksponering av netGroup.neighborCount eiendom * /offentlig funksjon får neighborCount (): int {return _neighborCount; } offentlig funksjon satt neighborCount (verdi: int): void {if (verdi == neighborCount) tilbake; _neighborCount = verdi; dispatchEvent (ny hendelse ('propertyChange'));} [bind] offentlig Var connectionState: String = STATE_DISCONNECTED [bind] offentlig Var tilkoblet: Boolean = false; [Bind] offentlig Var joinedGroup: Boolean = false;

La oss gi den enkelte offentlige eiendommer som argumenter: rtmfpServer, cirrusDevKey, applicationName og groupname. Dette bør høres kjent ut hvis du har lest de foregående trinnene. Twitter /* --------------------------------- --------------------------------- * //* --- Tilkoblings parametere --- * //* - -------------------------------------------------- --------------- * //** * Bruk en server rtmfp fungerer for lokale subnettet peer oppdagelse. * For bruken av internett med Cirrus server, noe som * rtmfp: //cirrus.adobe.com/"; vil være mer nyttig * /public Var _rtmfpServer: String =" rtmfp: "; /** * Hvis du bruker en Cirrus server, bør du legge til utvikleren nøkkelen her * /public Var _cirrusDevKey: String = ""; /** * applicationName er den felles delen av groupSpecifier navnet vi skal bruke * /public Var applicationName: String = "active.tutsplus. examples.netGroup /"; /** * groupname legges til applicationName å kunne håndtere flere * grupper for samme program enkelt * /public Var groupname:. String =" demoGroup ";

Det vil ha noen metode: koble (), koble () og Sendmessage () Den kobler metoden er nesten allerede kjent, som alle de viktige ting i. det har blitt sett i forrige trinn. Frakoblingen metoden er rett og slett en wrapper av netConnection.close () -metoden.

Sendmessage metoden vil bruke alt vi har forklart i VoNetGroupMessage struktur, det er derfor ingen overraskelse i gjennomføringen: det instantiates en VoNetGroupMessage objekt, fylle sine felt, så serial den ved hjelp av sitt objekt getter og bruke den for netGroup.post () -metoden
offentlig funksjon Sendmessage. (med forbehold: String, messageContents: Object): void { (! tilkoblet) hvis kaste "Feil prøver å sende en melding uten å være tilkoblet"; //Opprett meldingen å sende, sette min ID på den og fylle den //med innholdet Var melding: VoNetGroupMessage = new VoNetGroupMessage (); message.subject = forbehold; message.data = messageContents; message.sender = netConnection.nearID; netGroup.post (message.object);}

Vi har allerede hatt en rask titt på de NetStatusEvent verdier. tidligere trinn; det eneste som mangler delen er messageReceived handler, kalt når en NetGroup.Posting.Notify status er mottatt. I NetStatusEvent lytteren, instantiate vi meldingen ved hjelp objektet vi får, så gi det til messageReceived metode:
privat funksjon netGroup_statusHandler (event: NetStatusEvent): void {switch (event.info.code) {//{. ..} case "NetGroup.Posting.Notify": //messageReceived (ny VoNetGroupMessage (event.info.message)); gå i stykker; //Andre tilfeller ...

Dette messageReceived behandleren vil sende meldingen. Virksomheten lag som kanskje har abonnert på denne hendelsen vil da håndtere de indre detaljer om meldingen, jobben av netGroupManager, som håndterer peer-tilkoblinger, sende og motta data, er gjort. Twitter /** * NetGroup tilbakeringing for en netGroup.post (..) kommando. * *param Melding Object, oppbygging av dette objektet blir definert i Sendmessage handler * *see #sendMessage () * /private funksjon messageReceived (message: VoNetGroupMessage): void {//Broadcast melding til noen suscribers Var hendelse: NetGroupEvent = new NetGroupEvent (NetGroupEvent.POSTING); event.message = message.data; event.subject = message.subject; dispatchEvent (event);}

Som en milepæl, her kommer hele koden vår netgroup.NetGroupManager Klasse:
pakke netgroup {import flash.events.Event; import flash.events.EventDispatcher; import flash.events.IEventDispatcher; import flash.events.NetStatusEvent; import flash.net.GroupSpecifier; import flash.net.NetConnection; import flash.net.NetGroup; import flash.net.NetStream; import flash.sampler.getGetterInvocationCount; import flash.utils.getTimer; import helpers.DemoHelper; import mx.events.DynamicEvent; import org.osmf.net.NetConnectionCodes; import org.osmf.net.NetStreamCodes; /** * Hendelse sendt hver gang du mottar en melding. * /[Hendelses (name = "oppslaget", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt når netConnection og NetGroup tilkoblinger har vært * vellykket, og gruppen er klar til å brukes. * /[Hendelses (name = "connectedToGroup", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt netgruppen forbindelsen er lukket. * /[Hendelses (name = "disconnectedFromGroup", type = "netgroup.NetGroupEvent")] /** * Hendelse sendt netgruppen forbindelsen er lukket. * /[Hendelses (name = "neighborJoined", type = "netgroup.NetGroupEvent")] /** * * * /public class NetGroupManager strekker EventDispatcher {statisk offentlig konst STATE_DISCONNECTED: String = 'koblet'; statisk offentlig konst STATE_CONNECTING: String = 'koble'; statisk offentlig konst STATE_CONNECTED: String = "koblet"; /* ------------------------------------------------ ------------------ * //* --- Connection parametere --- * //* ---------------- -------------------------------------------------- * //** * Bruk en server rtmfp gjør arbeidet for lokale subnettet peer oppdagelse. * For bruken av internett med Cirrus server, noe som * rtmfp: //cirrus.adobe.com/"; vil være mer USEFULL * /public Var _rtmfpServer: String =" rtmfp: "; /** * Hvis du bruker en Cirrus server, bør du legge til utvikleren nøkkelen her * /public Var _cirrusDevKey: String = ""; /** * applicationName er den felles delen av groupSpecifier navnet vi skal bruke * /public Var applicationName: String = "active.tutsplus. examples.netGroup /"; /** * groupname legges til applicationName å kunne håndtere flere * grupper for samme program enkelt * /public Var groupname:. String =" demoGroup "; /* ------- -------------------------------------------------- --------- * //* --- Nyttig offentlige eiendommer for forvaltning av konsernet --- * //* -------------------- ---------------------------------------------- * /private Div _neighborCount: int; [Bind (event = 'propertyChange')] /** neighborCount er en offentlig eksponering av netGroup.neighborCount eiendom * /offentlig funksjon får neighborCount (): int {return _neighborCount; } Offentlig funksjon satt neighborCount (verdi: int): void {if (verdi == neighborCount) tilbake; _neighborCount = verdi; dispatchEvent (ny hendelse ('propertyChange')); } [Bind] offentlig Var connectionState: String = STATE_DISCONNECTED; [Bind] offentlig Var tilkoblet: Boolean = false; [Bind] offentlig Var joinedGroup: Boolean = false; beskyttet Var netConnection: NetConnection = null; beskyttet Var Netstream: Netstream = null; beskyttet Var nettgruppe: NetGroup = null; offentlig funksjon NetGroupManager (mål: IEventDispatcher = null) {super (target); } Offentlig funksjon koble (): void {_log ("Koble til '» + _rtmfpServer); connectionState = STATE_CONNECTING; netConnection = new NetConnection (); netConnection.addEventListener (NetStatusEvent.NET_STATUS, netConnection_netStatusHandler, falsk, 0, true); netConnection.connect (_rtmfpServer + _cirrusDevKey); } /** * Frakobling vil automatisk bli kalt når en nettgruppe tilkobling eller * en Netstream tilkoblingen vil bli avvist eller har mislyktes. * *see #netConnection_onDisconnect () * /Public funksjon frakobling (): void {if (netConnection) netConnection.close (); } Offentlig funksjon Sendmessage (subject: String, messageContents: Object): void {if (! Tilkoblet) kaste "Feil prøver å sende en melding uten å være tilkoblet"; 'G:01010103010c2c0e6163746976652e74757473706c75732e6578656d706c65732e6e657447726f75702f64656d6f47726f7570011b00070aee0000014e20' gå i stykker; gå i stykker; gå i stykker; gå i stykker; gå i stykker; gå i stykker; gå i stykker; gå i stykker; gå i stykker; import flash.events.Event; import flash.events.EventDispatcher; gå i stykker; gå i stykker; gå i stykker; gå i stykker; - >