修复集群传输bug

LICENSE

@@ -0,0 +1,674 @@
+                    GNU GENERAL PUBLIC LICENSE
+                       Version 3, 29 June 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+                            Preamble
+
+  The GNU General Public License is a free, copyleft license for
+software and other kinds of works.
+
+  The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works.  By contrast,
+the GNU General Public License is intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users.  We, the Free Software Foundation, use the
+GNU General Public License for most of our software; it applies also to
+any other work released this way by its authors.  You can apply it to
+your programs, too.
+
+  When we speak of free software, we are referring to freedom, not
+price.  Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+  To protect your rights, we need to prevent others from denying you
+these rights or asking you to surrender the rights.  Therefore, you have
+certain responsibilities if you distribute copies of the software, or if
+you modify it: responsibilities to respect the freedom of others.
+
+  For example, if you distribute copies of such a program, whether
+gratis or for a fee, you must pass on to the recipients the same
+freedoms that you received.  You must make sure that they, too, receive
+or can get the source code.  And you must show them these terms so they
+know their rights.
+
+  Developers that use the GNU GPL protect your rights with two steps:
+(1) assert copyright on the software, and (2) offer you this License
+giving you legal permission to copy, distribute and/or modify it.
+
+  For the developers' and authors' protection, the GPL clearly explains
+that there is no warranty for this free software.  For both users' and
+authors' sake, the GPL requires that modified versions be marked as
+changed, so that their problems will not be attributed erroneously to
+authors of previous versions.
+
+  Some devices are designed to deny users access to install or run
+modified versions of the software inside them, although the manufacturer
+can do so.  This is fundamentally incompatible with the aim of
+protecting users' freedom to change the software.  The systematic
+pattern of such abuse occurs in the area of products for individuals to
+use, which is precisely where it is most unacceptable.  Therefore, we
+have designed this version of the GPL to prohibit the practice for those
+products.  If such problems arise substantially in other domains, we
+stand ready to extend this provision to those domains in future versions
+of the GPL, as needed to protect the freedom of users.
+
+  Finally, every program is threatened constantly by software patents.
+States should not allow patents to restrict development and use of
+software on general-purpose computers, but in those that do, we wish to
+avoid the special danger that patents applied to a free program could
+make it effectively proprietary.  To prevent this, the GPL assures that
+patents cannot be used to render the program non-free.
+
+  The precise terms and conditions for copying, distribution and
+modification follow.
+
+                       TERMS AND CONDITIONS
+
+  0. Definitions.
+
+  "This License" refers to version 3 of the GNU General Public License.
+
+  "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+  "The Program" refers to any copyrightable work licensed under this
+License.  Each licensee is addressed as "you".  "Licensees" and
+"recipients" may be individuals or organizations.
+
+  To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy.  The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+  A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+  To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy.  Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+  To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies.  Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+  An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License.  If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+  1. Source Code.
+
+  The "source code" for a work means the preferred form of the work
+for making modifications to it.  "Object code" means any non-source
+form of a work.
+
+  A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+  The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form.  A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+  The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities.  However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work.  For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+  The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+  The Corresponding Source for a work in source code form is that
+same work.
+
+  2. Basic Permissions.
+
+  All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met.  This License explicitly affirms your unlimited
+permission to run the unmodified Program.  The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work.  This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+  You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force.  You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright.  Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+  Conveying under any other circumstances is permitted solely under
+the conditions stated below.  Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+  3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+  No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+  When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+  4. Conveying Verbatim Copies.
+
+  You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+  You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+  5. Conveying Modified Source Versions.
+
+  You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+    a) The work must carry prominent notices stating that you modified
+    it, and giving a relevant date.
+
+    b) The work must carry prominent notices stating that it is
+    released under this License and any conditions added under section
+    7.  This requirement modifies the requirement in section 4 to
+    "keep intact all notices".
+
+    c) You must license the entire work, as a whole, under this
+    License to anyone who comes into possession of a copy.  This
+    License will therefore apply, along with any applicable section 7
+    additional terms, to the whole of the work, and all its parts,
+    regardless of how they are packaged.  This License gives no
+    permission to license the work in any other way, but it does not
+    invalidate such permission if you have separately received it.
+
+    d) If the work has interactive user interfaces, each must display
+    Appropriate Legal Notices; however, if the Program has interactive
+    interfaces that do not display Appropriate Legal Notices, your
+    work need not make them do so.
+
+  A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit.  Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+  6. Conveying Non-Source Forms.
+
+  You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+    a) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by the
+    Corresponding Source fixed on a durable physical medium
+    customarily used for software interchange.
+
+    b) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by a
+    written offer, valid for at least three years and valid for as
+    long as you offer spare parts or customer support for that product
+    model, to give anyone who possesses the object code either (1) a
+    copy of the Corresponding Source for all the software in the
+    product that is covered by this License, on a durable physical
+    medium customarily used for software interchange, for a price no
+    more than your reasonable cost of physically performing this
+    conveying of source, or (2) access to copy the
+    Corresponding Source from a network server at no charge.
+
+    c) Convey individual copies of the object code with a copy of the
+    written offer to provide the Corresponding Source.  This
+    alternative is allowed only occasionally and noncommercially, and
+    only if you received the object code with such an offer, in accord
+    with subsection 6b.
+
+    d) Convey the object code by offering access from a designated
+    place (gratis or for a charge), and offer equivalent access to the
+    Corresponding Source in the same way through the same place at no
+    further charge.  You need not require recipients to copy the
+    Corresponding Source along with the object code.  If the place to
+    copy the object code is a network server, the Corresponding Source
+    may be on a different server (operated by you or a third party)
+    that supports equivalent copying facilities, provided you maintain
+    clear directions next to the object code saying where to find the
+    Corresponding Source.  Regardless of what server hosts the
+    Corresponding Source, you remain obligated to ensure that it is
+    available for as long as needed to satisfy these requirements.
+
+    e) Convey the object code using peer-to-peer transmission, provided
+    you inform other peers where the object code and Corresponding
+    Source of the work are being offered to the general public at no
+    charge under subsection 6d.
+
+  A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+  A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling.  In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage.  For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product.  A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+  "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source.  The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+  If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information.  But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+  The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed.  Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+  Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+  7. Additional Terms.
+
+  "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law.  If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+  When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it.  (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.)  You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+  Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+    a) Disclaiming warranty or limiting liability differently from the
+    terms of sections 15 and 16 of this License; or
+
+    b) Requiring preservation of specified reasonable legal notices or
+    author attributions in that material or in the Appropriate Legal
+    Notices displayed by works containing it; or
+
+    c) Prohibiting misrepresentation of the origin of that material, or
+    requiring that modified versions of such material be marked in
+    reasonable ways as different from the original version; or
+
+    d) Limiting the use for publicity purposes of names of licensors or
+    authors of the material; or
+
+    e) Declining to grant rights under trademark law for use of some
+    trade names, trademarks, or service marks; or
+
+    f) Requiring indemnification of licensors and authors of that
+    material by anyone who conveys the material (or modified versions of
+    it) with contractual assumptions of liability to the recipient, for
+    any liability that these contractual assumptions directly impose on
+    those licensors and authors.
+
+  All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10.  If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term.  If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+  If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+  Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+  8. Termination.
+
+  You may not propagate or modify a covered work except as expressly
+provided under this License.  Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+  However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+  Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+  Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License.  If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+  9. Acceptance Not Required for Having Copies.
+
+  You are not required to accept this License in order to receive or
+run a copy of the Program.  Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance.  However,
+nothing other than this License grants you permission to propagate or
+modify any covered work.  These actions infringe copyright if you do
+not accept this License.  Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+  10. Automatic Licensing of Downstream Recipients.
+
+  Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License.  You are not responsible
+for enforcing compliance by third parties with this License.
+
+  An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations.  If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+  You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License.  For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+  11. Patents.
+
+  A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based.  The
+work thus licensed is called the contributor's "contributor version".
+
+  A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version.  For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+  Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+  In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement).  To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+  If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients.  "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+  If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+  A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License.  You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+  Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+  12. No Surrender of Others' Freedom.
+
+  If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License.  If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all.  For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+  13. Use with the GNU Affero General Public License.
+
+  Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU Affero General Public License into a single
+combined work, and to convey the resulting work.  The terms of this
+License will continue to apply to the part which is the covered work,
+but the special requirements of the GNU Affero General Public License,
+section 13, concerning interaction through a network will apply to the
+combination as such.
+
+  14. Revised Versions of this License.
+
+  The Free Software Foundation may publish revised and/or new versions of
+the GNU General Public License from time to time.  Such new versions will
+be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+  Each version is given a distinguishing version number.  If the
+Program specifies that a certain numbered version of the GNU General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation.  If the Program does not specify a version number of the
+GNU General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+  If the Program specifies that a proxy can decide which future
+versions of the GNU General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+  Later license versions may give you additional or different
+permissions.  However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+  15. Disclaimer of Warranty.
+
+  THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW.  EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE.  THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU.  SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+  16. Limitation of Liability.
+
+  IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+  17. Interpretation of Sections 15 and 16.
+
+  If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+                     END OF TERMS AND CONDITIONS
+
+            How to Apply These Terms to Your New Programs
+
+  If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+  To do so, attach the following notices to the program.  It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+    <one line to give the program's name and a brief idea of what it does.>
+    Copyright (C) <year>  <name of author>
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program 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 <https://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+  If the program does terminal interaction, make it output a short
+notice like this when it starts in an interactive mode:
+
+    <program>  Copyright (C) <year>  <name of author>
+    This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
+    This is free software, and you are welcome to redistribute it
+    under certain conditions; type `show c' for details.
+
+The hypothetical commands `show w' and `show c' should show the appropriate
+parts of the General Public License.  Of course, your program's commands
+might be different; for a GUI interface, you would use an "about box".
+
+  You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU GPL, see
+<https://www.gnu.org/licenses/>.
+
+  The GNU General Public License does not permit incorporating your program
+into proprietary programs.  If your program is a subroutine library, you
+may consider it more useful to permit linking proprietary applications with
+the library.  If this is what you want to do, use the GNU Lesser General
+Public License instead of this License.  But first, please read
+<https://www.gnu.org/licenses/why-not-lgpl.html>.

config.toml

@@ -5,10 +5,10 @@ ListenAddr = ":8080"
 [Plugins.RTMP]
 ListenAddr = ":1935"
 [Plugins.GateWay]
-ListenAddr = ":81"
-#[Plugins.Cluster]
+ListenAddr = ":8081"
+[Plugins.Cluster]
 #Master = "localhost:2019"
-#ListenAddr = ":2019"
+ListenAddr = ":2019"
 #
 #[Plugins.Auth]
 #Key="www.monibuca.com"

dashboard/dist/css/app.93f68a59.css

@@ -1 +0,0 @@
-#app,body,html{height:100%}#app{font-family:Avenir,Helvetica,Arial,sans-serif;-webkit-font-smoothing:antialiased;-moz-osx-font-smoothing:grayscale;text-align:center;color:#184c18;position:relative}#app>div:first-child{position:absolute;top:10px;left:30px;font-size:x-large}.content{padding-top:60px}.feature-title[data-v-54efad41]{color:#eb5e46;font-weight:700;font-size:larger}p[data-v-54efad41]{margin:30px;font-size:20px}img[data-v-54efad41]{margin:20px}.root[data-v-e34eab40]{background:#d3d3d3}.root>img[data-v-e34eab40]{width:300px;margin:30px}.log-container{overflow-y:auto;max-height:360px}@-webkit-keyframes recording-data-v-1ed98600{0%{opacity:.2}50%{opacity:1}to{opacity:.2}}@keyframes recording-data-v-1ed98600{0%{opacity:.2}50%{opacity:1}to{opacity:.2}}.recording[data-v-1ed98600]{-webkit-animation:recording-data-v-1ed98600 1s infinite;animation:recording-data-v-1ed98600 1s infinite}.layout[data-v-1ed98600]{padding-bottom:30px;display:-webkit-box;display:-ms-flexbox;display:flex;-ms-flex-wrap:wrap;flex-wrap:wrap}.room[data-v-1ed98600]{width:250px;margin:10px;text-align:left}.empty[data-v-1ed98600]{color:#eb5e46;width:100%;min-height:500px;-webkit-box-pack:center;-ms-flex-pack:center;justify-content:center;-webkit-box-align:center;-ms-flex-align:center;align-items:center}.empty[data-v-1ed98600],.status[data-v-1ed98600]{display:-webkit-box;display:-ms-flexbox;display:flex}.status[data-v-1ed98600]{position:fixed;left:5px;bottom:10px}.status>div[data-v-1ed98600]{margin:0 5px}

dashboard/dist/css/app.ce470878.css

@@ -0,0 +1 @@
+#app,body,html{height:100%}#app{font-family:Avenir,Helvetica,Arial,sans-serif;-webkit-font-smoothing:antialiased;-moz-osx-font-smoothing:grayscale;text-align:center;color:#184c18;position:relative}#app>div:first-child{position:absolute;top:10px;left:30px;font-size:x-large}.content{padding-top:60px}.feature-title[data-v-54efad41]{color:#eb5e46;font-weight:700;font-size:larger}p[data-v-54efad41]{margin:30px;font-size:20px}img[data-v-54efad41]{margin:20px}.root[data-v-e34eab40]{background:#d3d3d3}.root>img[data-v-e34eab40]{width:300px;margin:30px}.records[data-v-7d5ab110]{display:-webkit-box;display:-ms-flexbox;display:flex;-ms-flex-wrap:wrap;flex-wrap:wrap;padding:0 15px}.records>[data-v-7d5ab110]{width:200px}.log-container{overflow-y:auto;max-height:500px}@-webkit-keyframes recording-data-v-65ac4b48{0%{opacity:.2}50%{opacity:1}to{opacity:.2}}@keyframes recording-data-v-65ac4b48{0%{opacity:.2}50%{opacity:1}to{opacity:.2}}.recording[data-v-65ac4b48]{-webkit-animation:recording-data-v-65ac4b48 1s infinite;animation:recording-data-v-65ac4b48 1s infinite}.layout[data-v-65ac4b48]{padding-bottom:30px;display:-webkit-box;display:-ms-flexbox;display:flex;-ms-flex-wrap:wrap;flex-wrap:wrap}.room[data-v-65ac4b48]{width:250px;margin:10px;text-align:left}.empty[data-v-65ac4b48]{color:#eb5e46;width:100%;min-height:500px;-webkit-box-pack:center;-ms-flex-pack:center;justify-content:center;-webkit-box-align:center;-ms-flex-align:center;align-items:center}.empty[data-v-65ac4b48],.status[data-v-65ac4b48]{display:-webkit-box;display:-ms-flexbox;display:flex}.status[data-v-65ac4b48]{position:fixed;left:5px;bottom:10px}.status>div[data-v-65ac4b48]{margin:0 5px}

dashboard/dist/index.html

@@ -1 +1 @@
-<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.93f68a59.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.00b4a97a.js rel=preload as=script><link href=/js/chunk-vendors.ae8ac63d.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.93f68a59.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ae8ac63d.js></script><script src=/js/app.00b4a97a.js></script></body></html>
+<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.ce470878.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.017fb959.js rel=preload as=script><link href=/js/chunk-vendors.ebc28a73.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.ce470878.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ebc28a73.js></script><script src=/js/app.017fb959.js></script></body></html>

dashboard/dist/jessibuca/renderer.js

@@ -9,7 +9,7 @@ function Jessibuca(opt) {
         this.initBuffers();
         this.initTextures();
     };
-    this.decoderWorker = new Worker(opt.decoder || '264_mp3.js')
+    this.decoderWorker = new Worker(opt.decoder || 'ff.js')
     var _this = this
     function draw(output) {
         _this.drawNextOutputPicture(_this.width, _this.height, null, output)
@@ -118,12 +118,15 @@ Jessibuca.prototype.playAudio = function (data) {
         }
         // setTimeout(playNextBuffer, buffer.duration * 1000)
     }
-    var tryPlay = function (buffer) {
+    var decodeAudio = function () {
         if (decodeQueue.length) {
-            context.decodeAudioData(decodeQueue.shift(), tryPlay, console.error);
+            context.decodeAudioData(decodeQueue.shift(), tryPlay, decodeAudio);
         } else {
             isDecoding = false
         }
+    }
+    var tryPlay = function (buffer) {
+        decodeAudio()
         if (isPlaying) {
             audioBuffers.push(buffer);
         } else {
@@ -134,7 +137,7 @@ Jessibuca.prototype.playAudio = function (data) {
         decodeQueue.push(...data)
         if (!isDecoding) {
             isDecoding = true
-            context.decodeAudioData(decodeQueue.shift(), tryPlay, console.error);
+            decodeAudio()
         }
     }
     this.playAudio = playAudio
@@ -452,7 +455,7 @@ Jessibuca.prototype.close = function () {
     this.decoderWorker.postMessage({ cmd: "close" })
     this.contextGL.clear(this.contextGL.COLOR_BUFFER_BIT);
 }
-Jessibuca.prototype.destroy = function(){
+Jessibuca.prototype.destroy = function () {
     this.decoderWorker.terminate()
 }
 Jessibuca.prototype.play = function (url) {

dashboard/docs/design.md

@@ -0,0 +1,43 @@
+# Monibuca设计思想
+
+## 背景
+
+市面上的流媒体服务器不可谓不多，从本人的第一份工作起，就一直接触和研究了形形色色的流媒体服务器，从最早的**FCS**(全称Flash Communication Server),后来改名为**FMS**(全称Flash Media Server),到Red5(java语言开发)，到**CrtmpServer**(C++开发)，让我对流媒体服务器的基本原理有了深刻的认识。当时本人痴迷C#，于是乎在业余时间对crtmpServer的代码进行移植，用C#仿照着写了一遍取名为[csharprtmp](https://github.com/langhuihui/csharprtmp)，并且适当的增强了一些功能，于是对rtmp协议了如指掌。后来Adobe推出了RTMFP协议，是一种p2p协议，十分节省带宽。我就又开始研究一款名为**OpenRTMFP**的开源项目，后来该项目改名为**MonaServer**。我在起基础上进行了扩展，实现了一些例如录制flv，shareObject等原本FMS有的功能。后开发出了HTML5直播技术（现在命名为Jessibuca,尚未开源)，采用的传输协议就是WebSocket传输裸的视频流的方式，属于私有协议。而Server当时就使用的MonaServer。但当时遇到一个问题，C++的内存泄漏问题，这个一直没有很好的解决。遂决定放弃使用MonaServer转而使用srs，而srs要用一个很简单的go写的小程序将http-flv转换成WebSocket的Flv来适配我的Jessibuca，感觉最好能直接修改srs来实现这个功能。对srs的源码研究了一小段时间后放弃了，因为C++代码过于难写，容易出现bug。后来转而使用golang写的**gortmp**作为server，同样对其进行了扩展，而且进展十分顺利，golang的开发效率令人惊叹，而且其协程的特性很完美的处理了流媒体服务器的并发的场景。所以使用golang写的流媒体服务器项目很多，github上随便一搜就有很多，比如**livego**、**joy4**等。期间还接触到一位使用Node.js实现的流媒体服务器Node Media Server，我也和作者交流了许多，收益良多。
+
+### 现有项目的不足
+虽然流媒体服务器项目很多，但在我使用过程中遇到了几个痛点
+
+1. 功能太多太重，往往大而全，不够轻量 很多号称轻量的项目最后都会越来越重
+2. 扩展性弱，由于功能复杂，设计之初没有提供良好的扩展性，有些项目带有脚本支持，如FMS和MonaServer，但执行脚本会牺牲性能，而且脚本和原生代码相比，功能限制很大，只能实现业务逻辑而不是流媒体服务器本身的功能扩展。
+3. 缺少图形管理界面，FMS是配套有图形管理界面的，当然FMS的问题是商业软件需要付费，源码也是不可见的。
+
+综上所述，本人在吸收了以上诸多流媒体服务器的设计后，完成了Monibuca这款golang编写的流媒体开发框架的编写
+
+### 受到vue渐进式思想的影响
+vue渐进式框架的设计思想非常棒，那么是否可以用来设计流媒体服务器，使得流媒体服务器不只是一个服务器，而是一个开发框架，让开发者可以定制化自己的流媒体服务器呢？答案是肯定的。当然我们需要更多的抽象。
+
+## 流媒体服务器的核心
+
+流媒体服务器的核心是**转发**二字。当你去研究一款流媒体服务器的时候，会有海量的代码阻碍你看清其核心逻辑。包括：
+
+1. 多媒体格式定义、解析，如Flv、MP4、MP3、H264、AAC等等
+2. 传输协议的解析，如RTMP家族、AMF、HTTP、RTSP、HLS、WebSocket等等
+3. 各种工具类，用来读取字节的缓冲、大小端转换、加解密算法、等等
+
+大部分流媒体服务器都是基于rtmp协议之上扩展而来，这是历史原因造成的，所以功能不能很好的分离，耦合度很高。往往牵一发而动全身。其实所谓的流媒体服务器本质上就是把发布者的数据经过服务器转发到订阅者手里播放，起一个中转作用。至于什么协议格式，什么媒体格式都是属于扩展功能。所以最轻量的服务器应该不包含任何协议格式，任何媒体格式，仅仅只是完成中转。再说的直白一点核心代码就是一个for循环。
+```go
+for _, v := range r.Subscribers {
+    v.sendVideo(video)
+}
+```
+其他都是围绕这个for循环展开。所有的流媒体服务器代码里面都有这个for循环，写法稍有不同，但本质相同。
+
+### 核心概念
+
+
+基于这个循环，我们需要思考两个问题：
+1. 如何高效的循环（性能问题）
+2. 如何对接不同的协议（扩展性）
+
+第一个问题，golang的性能算是很好的，那么重点就在于减少内存的分配上，池化是一个不错的选择，所以尽量池化，在Monibuca中对`[]byte`类型，采用了[github.com/funny/slab](https://github.com/funny/slab)包来管理。其他结构体就用系统自带的pool包来池化对象。对于协程的使用，在多次迭代后，已经使用了最少的协程来支持并发性。
+

dashboard/package-lock.json

@@ -123,6 +123,44 @@
         "tslib": "1.10.0"
       }
     },
+    "@antv/g6": {
+      "version": "3.2.9",
+      "resolved": "https://registry.npm.taobao.org/@antv/g6/download/@antv/g6-3.2.9.tgz",
+      "integrity": "sha1-V4k4YKrE3iZUTz1dSoG4jWXVK9k=",
+      "requires": {
+        "@antv/g": "3.4.7",
+        "@antv/hierarchy": "0.6.1",
+        "@antv/util": "1.3.1",
+        "d3": "5.15.0",
+        "d3-force": "2.0.1",
+        "d3-sankey": "0.12.3",
+        "dagre": "0.8.5",
+        "numeric": "1.2.6",
+        "numericjs": "1.2.6"
+      },
+      "dependencies": {
+        "@antv/g": {
+          "version": "3.4.7",
+          "resolved": "https://registry.npm.taobao.org/@antv/g/download/@antv/g-3.4.7.tgz",
+          "integrity": "sha1-1CCM07f4XVEvp19l0YXIoFoYHuU=",
+          "requires": {
+            "@antv/gl-matrix": "2.7.1",
+            "@antv/util": "1.3.1",
+            "d3-ease": "1.0.6",
+            "d3-interpolate": "1.1.6",
+            "d3-timer": "1.0.10"
+          }
+        },
+        "@antv/util": {
+          "version": "1.3.1",
+          "resolved": "https://registry.npm.taobao.org/@antv/util/download/@antv/util-1.3.1.tgz?cache=0&sync_timestamp=1572438102677&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2F%40antv%2Futil%2Fdownload%2F%40antv%2Futil-1.3.1.tgz",
+          "integrity": "sha1-MKNLIB/5Em7A1YxyyBZqnD5kTM0=",
+          "requires": {
+            "@antv/gl-matrix": "2.7.1"
+          }
+        }
+      }
+    },
     "@antv/gl-matrix": {
       "version": "2.7.1",
       "resolved": "https://registry.npm.taobao.org/@antv/gl-matrix/download/@antv/gl-matrix-2.7.1.tgz",
@@ -141,6 +179,24 @@
         "tslib": "1.10.0"
       }
     },
+    "@antv/hierarchy": {
+      "version": "0.6.1",
+      "resolved": "https://registry.npm.taobao.org/@antv/hierarchy/download/@antv/hierarchy-0.6.1.tgz",
+      "integrity": "sha1-2oH6FUTNTj/17D+WAfv4FC9h7yw=",
+      "requires": {
+        "@antv/util": "1.3.1"
+      },
+      "dependencies": {
+        "@antv/util": {
+          "version": "1.3.1",
+          "resolved": "https://registry.npm.taobao.org/@antv/util/download/@antv/util-1.3.1.tgz?cache=0&sync_timestamp=1572438102677&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2F%40antv%2Futil%2Fdownload%2F%40antv%2Futil-1.3.1.tgz",
+          "integrity": "sha1-MKNLIB/5Em7A1YxyyBZqnD5kTM0=",
+          "requires": {
+            "@antv/gl-matrix": "2.7.1"
+          }
+        }
+      }
+    },
     "@antv/matrix-util": {
       "version": "2.0.4",
       "resolved": "https://registry.npm.taobao.org/@antv/matrix-util/download/@antv/matrix-util-2.0.4.tgz",
@@ -4409,8 +4465,7 @@
     "commander": {
       "version": "2.20.3",
       "resolved": "https://registry.npm.taobao.org/commander/download/commander-2.20.3.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fcommander%2Fdownload%2Fcommander-2.20.3.tgz",
-      "integrity": "sha1-/UhehMA+tIgcIHIrpIA16FMa6zM=",
-      "dev": true
+      "integrity": "sha1-/UhehMA+tIgcIHIrpIA16FMa6zM="
     },
     "common-tags": {
       "version": "1.8.0",
@@ -5130,16 +5185,171 @@
         "type": "1.2.0"
       }
     },
+    "d3": {
+      "version": "5.15.0",
+      "resolved": "https://registry.npm.taobao.org/d3/download/d3-5.15.0.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3%2Fdownload%2Fd3-5.15.0.tgz",
+      "integrity": "sha1-/9RJWOajy4pZqEQpxFQpuLylZ3o=",
+      "requires": {
+        "d3-array": "1.2.4",
+        "d3-axis": "1.0.12",
+        "d3-brush": "1.1.5",
+        "d3-chord": "1.0.6",
+        "d3-collection": "1.0.7",
+        "d3-color": "1.4.0",
+        "d3-contour": "1.3.2",
+        "d3-dispatch": "1.0.6",
+        "d3-drag": "1.2.5",
+        "d3-dsv": "1.2.0",
+        "d3-ease": "1.0.6",
+        "d3-fetch": "1.1.2",
+        "d3-force": "1.2.1",
+        "d3-format": "1.4.3",
+        "d3-geo": "1.11.9",
+        "d3-hierarchy": "1.1.9",
+        "d3-interpolate": "1.1.6",
+        "d3-path": "1.0.9",
+        "d3-polygon": "1.0.6",
+        "d3-quadtree": "1.0.7",
+        "d3-random": "1.1.2",
+        "d3-scale": "2.2.2",
+        "d3-scale-chromatic": "1.5.0",
+        "d3-selection": "1.4.1",
+        "d3-shape": "1.3.7",
+        "d3-time": "1.1.0",
+        "d3-time-format": "2.2.3",
+        "d3-timer": "1.0.10",
+        "d3-transition": "1.3.2",
+        "d3-voronoi": "1.1.4",
+        "d3-zoom": "1.8.3"
+      },
+      "dependencies": {
+        "d3-force": {
+          "version": "1.2.1",
+          "resolved": "https://registry.npm.taobao.org/d3-force/download/d3-force-1.2.1.tgz",
+          "integrity": "sha1-/Sml0f8YHJ5/BmnkvXK9sOkU7As=",
+          "requires": {
+            "d3-collection": "1.0.7",
+            "d3-dispatch": "1.0.6",
+            "d3-quadtree": "1.0.7",
+            "d3-timer": "1.0.10"
+          }
+        }
+      }
+    },
+    "d3-array": {
+      "version": "1.2.4",
+      "resolved": "https://registry.npm.taobao.org/d3-array/download/d3-array-1.2.4.tgz",
+      "integrity": "sha1-Y1zk1e6nWfb2BYY9vPww7cc39x8="
+    },
+    "d3-axis": {
+      "version": "1.0.12",
+      "resolved": "https://registry.npm.taobao.org/d3-axis/download/d3-axis-1.0.12.tgz",
+      "integrity": "sha1-zfILohDPu0N5WvM3Vohvs2ONqsk="
+    },
+    "d3-brush": {
+      "version": "1.1.5",
+      "resolved": "https://registry.npm.taobao.org/d3-brush/download/d3-brush-1.1.5.tgz",
+      "integrity": "sha1-BmuOhNF7GSmGAwRGyXwPun4brNw=",
+      "requires": {
+        "d3-dispatch": "1.0.6",
+        "d3-drag": "1.2.5",
+        "d3-interpolate": "1.1.6",
+        "d3-selection": "1.4.1",
+        "d3-transition": "1.3.2"
+      }
+    },
+    "d3-chord": {
+      "version": "1.0.6",
+      "resolved": "https://registry.npm.taobao.org/d3-chord/download/d3-chord-1.0.6.tgz?cache=0&sync_timestamp=1575418695102&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-chord%2Fdownload%2Fd3-chord-1.0.6.tgz",
+      "integrity": "sha1-MJFX4/LbLHUvAoD+3TXyBnzLsV8=",
+      "requires": {
+        "d3-array": "1.2.4",
+        "d3-path": "1.0.9"
+      }
+    },
+    "d3-collection": {
+      "version": "1.0.7",
+      "resolved": "https://registry.npm.taobao.org/d3-collection/download/d3-collection-1.0.7.tgz",
+      "integrity": "sha1-NJvSqpl32wcQkcExRNXk8WtbMQ4="
+    },
     "d3-color": {
       "version": "1.4.0",
       "resolved": "https://registry.npm.taobao.org/d3-color/download/d3-color-1.4.0.tgz",
       "integrity": "sha1-icRamV7Xc7EzFPBkYN8m1gug7K8="
     },
+    "d3-contour": {
+      "version": "1.3.2",
+      "resolved": "https://registry.npm.taobao.org/d3-contour/download/d3-contour-1.3.2.tgz",
+      "integrity": "sha1-ZSqs1QDSJkyzQjzuENtp9vWb6tM=",
+      "requires": {
+        "d3-array": "1.2.4"
+      }
+    },
+    "d3-dispatch": {
+      "version": "1.0.6",
+      "resolved": "https://registry.npm.taobao.org/d3-dispatch/download/d3-dispatch-1.0.6.tgz",
+      "integrity": "sha1-ANN7zuTdjNl3Kd2JOgrCnKq6XVg="
+    },
+    "d3-drag": {
+      "version": "1.2.5",
+      "resolved": "https://registry.npm.taobao.org/d3-drag/download/d3-drag-1.2.5.tgz",
+      "integrity": "sha1-JTf0UazTnTFAZne33HfIL32Yj3A=",
+      "requires": {
+        "d3-dispatch": "1.0.6",
+        "d3-selection": "1.4.1"
+      }
+    },
+    "d3-dsv": {
+      "version": "1.2.0",
+      "resolved": "https://registry.npm.taobao.org/d3-dsv/download/d3-dsv-1.2.0.tgz?cache=0&sync_timestamp=1573934576301&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-dsv%2Fdownload%2Fd3-dsv-1.2.0.tgz",
+      "integrity": "sha1-nV91w6X4q9YR900/WEew1DOLiFw=",
+      "requires": {
+        "commander": "2.20.3",
+        "iconv-lite": "0.4.24",
+        "rw": "1.3.3"
+      }
+    },
     "d3-ease": {
       "version": "1.0.6",
       "resolved": "https://registry.npm.taobao.org/d3-ease/download/d3-ease-1.0.6.tgz",
       "integrity": "sha1-69ttoi36wKIiIvLU2gb2bEFqDsA="
     },
+    "d3-fetch": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npm.taobao.org/d3-fetch/download/d3-fetch-1.1.2.tgz",
+      "integrity": "sha1-lXyPvG1EgFmboZGxslGL+Gs+G+I=",
+      "requires": {
+        "d3-dsv": "1.2.0"
+      }
+    },
+    "d3-force": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npm.taobao.org/d3-force/download/d3-force-2.0.1.tgz",
+      "integrity": "sha1-MXUO7oxDU1MB1XEZW/loO+2lNOI=",
+      "requires": {
+        "d3-dispatch": "1.0.6",
+        "d3-quadtree": "1.0.7",
+        "d3-timer": "1.0.10"
+      }
+    },
+    "d3-format": {
+      "version": "1.4.3",
+      "resolved": "https://registry.npm.taobao.org/d3-format/download/d3-format-1.4.3.tgz",
+      "integrity": "sha1-To603/P9y4kahInsbmmGAcQblvE="
+    },
+    "d3-geo": {
+      "version": "1.11.9",
+      "resolved": "https://registry.npm.taobao.org/d3-geo/download/d3-geo-1.11.9.tgz",
+      "integrity": "sha1-d+rtFLpi/CwK71XNKUOEnIZveuY=",
+      "requires": {
+        "d3-array": "1.2.4"
+      }
+    },
+    "d3-hierarchy": {
+      "version": "1.1.9",
+      "resolved": "https://registry.npm.taobao.org/d3-hierarchy/download/d3-hierarchy-1.1.9.tgz?cache=0&sync_timestamp=1574108571076&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-hierarchy%2Fdownload%2Fd3-hierarchy-1.1.9.tgz",
+      "integrity": "sha1-L2vuJMqupD+Nw3VF+gFihVlkeoM="
+    },
     "d3-interpolate": {
       "version": "1.1.6",
       "resolved": "https://registry.npm.taobao.org/d3-interpolate/download/d3-interpolate-1.1.6.tgz",
@@ -5148,16 +5358,132 @@
         "d3-color": "1.4.0"
       }
     },
+    "d3-path": {
+      "version": "1.0.9",
+      "resolved": "https://registry.npm.taobao.org/d3-path/download/d3-path-1.0.9.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-path%2Fdownload%2Fd3-path-1.0.9.tgz",
+      "integrity": "sha1-SMBQux/owmJJOoyvVSTj6VkXAc8="
+    },
+    "d3-polygon": {
+      "version": "1.0.6",
+      "resolved": "https://registry.npm.taobao.org/d3-polygon/download/d3-polygon-1.0.6.tgz",
+      "integrity": "sha1-C/jLgYCm3BB/UY3feXXhKrv7044="
+    },
+    "d3-quadtree": {
+      "version": "1.0.7",
+      "resolved": "https://registry.npm.taobao.org/d3-quadtree/download/d3-quadtree-1.0.7.tgz",
+      "integrity": "sha1-youE33u1N2P+PC8kvUNRN/TlMTU="
+    },
+    "d3-random": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npm.taobao.org/d3-random/download/d3-random-1.1.2.tgz",
+      "integrity": "sha1-KDO+fBJDYL+eLT/U8zhHz+bKspE="
+    },
     "d3-regression": {
       "version": "1.3.4",
       "resolved": "https://registry.npm.taobao.org/d3-regression/download/d3-regression-1.3.4.tgz",
       "integrity": "sha1-o0FLGr5aINRqII2V5WWkGL6aDiM="
     },
+    "d3-sankey": {
+      "version": "0.12.3",
+      "resolved": "https://registry.npm.taobao.org/d3-sankey/download/d3-sankey-0.12.3.tgz",
+      "integrity": "sha1-s8JoYnvXLl2AM26N5qy/7J0V0B0=",
+      "requires": {
+        "d3-array": "1.2.4",
+        "d3-shape": "1.3.7"
+      }
+    },
+    "d3-scale": {
+      "version": "2.2.2",
+      "resolved": "https://registry.npm.taobao.org/d3-scale/download/d3-scale-2.2.2.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-scale%2Fdownload%2Fd3-scale-2.2.2.tgz",
+      "integrity": "sha1-TogOCydFrKrd0+3iap6Qip4XuB8=",
+      "requires": {
+        "d3-array": "1.2.4",
+        "d3-collection": "1.0.7",
+        "d3-format": "1.4.3",
+        "d3-interpolate": "1.1.6",
+        "d3-time": "1.1.0",
+        "d3-time-format": "2.2.3"
+      }
+    },
+    "d3-scale-chromatic": {
+      "version": "1.5.0",
+      "resolved": "https://registry.npm.taobao.org/d3-scale-chromatic/download/d3-scale-chromatic-1.5.0.tgz",
+      "integrity": "sha1-VOMz/HghL0ObFGQftVgB3YETWpg=",
+      "requires": {
+        "d3-color": "1.4.0",
+        "d3-interpolate": "1.1.6"
+      }
+    },
+    "d3-selection": {
+      "version": "1.4.1",
+      "resolved": "https://registry.npm.taobao.org/d3-selection/download/d3-selection-1.4.1.tgz",
+      "integrity": "sha1-mO7bvghfvaW6+i+ePzovTX1iKpg="
+    },
+    "d3-shape": {
+      "version": "1.3.7",
+      "resolved": "https://registry.npm.taobao.org/d3-shape/download/d3-shape-1.3.7.tgz",
+      "integrity": "sha1-32OAG+B7yYa8VPY3ibT+UCmStdc=",
+      "requires": {
+        "d3-path": "1.0.9"
+      }
+    },
+    "d3-time": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npm.taobao.org/d3-time/download/d3-time-1.1.0.tgz",
+      "integrity": "sha1-seGdMH2unJALflsl/8XcwkmooPE="
+    },
+    "d3-time-format": {
+      "version": "2.2.3",
+      "resolved": "https://registry.npm.taobao.org/d3-time-format/download/d3-time-format-2.2.3.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-time-format%2Fdownload%2Fd3-time-format-2.2.3.tgz",
+      "integrity": "sha1-DJoS7ig0KyA35eoc8LnrTddfKcs=",
+      "requires": {
+        "d3-time": "1.1.0"
+      }
+    },
     "d3-timer": {
       "version": "1.0.10",
       "resolved": "https://registry.npm.taobao.org/d3-timer/download/d3-timer-1.0.10.tgz?cache=0&sync_timestamp=1573934576216&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fd3-timer%2Fdownload%2Fd3-timer-1.0.10.tgz",
       "integrity": "sha1-3+dripF0iDGxO22ceT/71QjdneU="
     },
+    "d3-transition": {
+      "version": "1.3.2",
+      "resolved": "https://registry.npm.taobao.org/d3-transition/download/d3-transition-1.3.2.tgz",
+      "integrity": "sha1-qY7yFRvo2GAFQ0NMHKgBQK4js5g=",
+      "requires": {
+        "d3-color": "1.4.0",
+        "d3-dispatch": "1.0.6",
+        "d3-ease": "1.0.6",
+        "d3-interpolate": "1.1.6",
+        "d3-selection": "1.4.1",
+        "d3-timer": "1.0.10"
+      }
+    },
+    "d3-voronoi": {
+      "version": "1.1.4",
+      "resolved": "https://registry.npm.taobao.org/d3-voronoi/download/d3-voronoi-1.1.4.tgz",
+      "integrity": "sha1-3Tx412U9K7NZKErkeGRdlZRMgpc="
+    },
+    "d3-zoom": {
+      "version": "1.8.3",
+      "resolved": "https://registry.npm.taobao.org/d3-zoom/download/d3-zoom-1.8.3.tgz",
+      "integrity": "sha1-tqPb5zjHdjEhzQW4p3lf/hf0/Ao=",
+      "requires": {
+        "d3-dispatch": "1.0.6",
+        "d3-drag": "1.2.5",
+        "d3-interpolate": "1.1.6",
+        "d3-selection": "1.4.1",
+        "d3-transition": "1.3.2"
+      }
+    },
+    "dagre": {
+      "version": "0.8.5",
+      "resolved": "https://registry.npm.taobao.org/dagre/download/dagre-0.8.5.tgz",
+      "integrity": "sha1-ujCwBV2sErbB/MJHgXRCd30Gr+4=",
+      "requires": {
+        "graphlib": "2.1.8",
+        "lodash": "4.17.15"
+      }
+    },
     "dashdash": {
       "version": "1.14.1",
       "resolved": "https://registry.npm.taobao.org/dashdash/download/dashdash-1.14.1.tgz",
@@ -7568,6 +7894,14 @@
       "integrity": "sha1-ShL/G2A3bvCYYsIJPt2Qgyi+hCM=",
       "dev": true
     },
+    "graphlib": {
+      "version": "2.1.8",
+      "resolved": "https://registry.npm.taobao.org/graphlib/download/graphlib-2.1.8.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fgraphlib%2Fdownload%2Fgraphlib-2.1.8.tgz",
+      "integrity": "sha1-V2HUFHN4cAhMkux7XbywWSydNdo=",
+      "requires": {
+        "lodash": "4.17.15"
+      }
+    },
     "gray-matter": {
       "version": "4.0.2",
       "resolved": "https://registry.npm.taobao.org/gray-matter/download/gray-matter-4.0.2.tgz",
@@ -8023,7 +8357,6 @@
       "version": "0.4.24",
       "resolved": "https://registry.npm.taobao.org/iconv-lite/download/iconv-lite-0.4.24.tgz?cache=0&sync_timestamp=1579333981154&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Ficonv-lite%2Fdownload%2Ficonv-lite-0.4.24.tgz",
       "integrity": "sha1-ICK0sl+93CHS9SSXSkdKr+czkIs=",
-      "dev": true,
       "requires": {
         "safer-buffer": "2.1.2"
       }
@@ -9306,8 +9639,7 @@
     "lodash": {
       "version": "4.17.15",
       "resolved": "https://registry.npm.taobao.org/lodash/download/lodash-4.17.15.tgz?cache=0&sync_timestamp=1563508077056&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Flodash%2Fdownload%2Flodash-4.17.15.tgz",
-      "integrity": "sha1-tEf2ZwoEVbv+7dETku/zMOoJdUg=",
-      "dev": true
+      "integrity": "sha1-tEf2ZwoEVbv+7dETku/zMOoJdUg="
     },
     "lodash._reinterpolate": {
       "version": "3.0.0",
@@ -10296,6 +10628,16 @@
       "integrity": "sha1-CXtgK1NCKlIsGvuHkDGDNpQaAR0=",
       "dev": true
     },
+    "numeric": {
+      "version": "1.2.6",
+      "resolved": "https://registry.npm.taobao.org/numeric/download/numeric-1.2.6.tgz",
+      "integrity": "sha1-dlsCvvl5iPz4gNTrPza4D6MTNao="
+    },
+    "numericjs": {
+      "version": "1.2.6",
+      "resolved": "https://registry.npm.taobao.org/numericjs/download/numericjs-1.2.6.tgz",
+      "integrity": "sha1-wNryXEvLIuBDv4NEP5856LM2eYs="
+    },
     "oauth-sign": {
       "version": "0.9.0",
       "resolved": "https://registry.npm.taobao.org/oauth-sign/download/oauth-sign-0.9.0.tgz",
@@ -13155,6 +13497,11 @@
         "aproba": "1.2.0"
       }
     },
+    "rw": {
+      "version": "1.3.3",
+      "resolved": "https://registry.npm.taobao.org/rw/download/rw-1.3.3.tgz",
+      "integrity": "sha1-P4Yt+pGrdmsUiF700BEkv9oHT7Q="
+    },
     "rxjs": {
       "version": "6.5.4",
       "resolved": "https://registry.npm.taobao.org/rxjs/download/rxjs-6.5.4.tgz?cache=0&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Frxjs%2Fdownload%2Frxjs-6.5.4.tgz",
@@ -13182,8 +13529,7 @@
     "safer-buffer": {
       "version": "2.1.2",
       "resolved": "https://registry.npm.taobao.org/safer-buffer/download/safer-buffer-2.1.2.tgz",
-      "integrity": "sha1-RPoWGwGHuVSd2Eu5GAL5vYOFzWo=",
-      "dev": true
+      "integrity": "sha1-RPoWGwGHuVSd2Eu5GAL5vYOFzWo="
     },
     "sax": {
       "version": "1.2.4",

dashboard/package.json

@@ -11,6 +11,7 @@
   },
   "dependencies": {
     "@antv/g2plot": "^0.11.22",
+    "@antv/g6": "^3.2.9",
     "core-js": "^3.4.4",
     "view-design": "^4.0.0",
     "vue": "^2.6.10",

dashboard/public/jessibuca/renderer.js

@@ -9,7 +9,7 @@ function Jessibuca(opt) {
         this.initBuffers();
         this.initTextures();
     };
-    this.decoderWorker = new Worker(opt.decoder || '264_mp3.js')
+    this.decoderWorker = new Worker(opt.decoder || 'ff.js')
     var _this = this
     function draw(output) {
         _this.drawNextOutputPicture(_this.width, _this.height, null, output)
@@ -118,12 +118,15 @@ Jessibuca.prototype.playAudio = function (data) {
         }
         // setTimeout(playNextBuffer, buffer.duration * 1000)
     }
-    var tryPlay = function (buffer) {
+    var decodeAudio = function () {
         if (decodeQueue.length) {
-            context.decodeAudioData(decodeQueue.shift(), tryPlay, console.error);
+            context.decodeAudioData(decodeQueue.shift(), tryPlay, decodeAudio);
         } else {
             isDecoding = false
         }
+    }
+    var tryPlay = function (buffer) {
+        decodeAudio()
         if (isPlaying) {
             audioBuffers.push(buffer);
         } else {
@@ -134,7 +137,7 @@ Jessibuca.prototype.playAudio = function (data) {
         decodeQueue.push(...data)
         if (!isDecoding) {
             isDecoding = true
-            context.decodeAudioData(decodeQueue.shift(), tryPlay, console.error);
+            decodeAudio()
         }
     }
     this.playAudio = playAudio
@@ -452,7 +455,7 @@ Jessibuca.prototype.close = function () {
     this.decoderWorker.postMessage({ cmd: "close" })
     this.contextGL.clear(this.contextGL.COLOR_BUFFER_BIT);
 }
-Jessibuca.prototype.destroy = function(){
+Jessibuca.prototype.destroy = function () {
     this.decoderWorker.terminate()
 }
 Jessibuca.prototype.play = function (url) {

dashboard/src/App.vue

@@ -1,80 +1,71 @@
 <template>
-    <div id="app">
-        <div>Monibuca</div>
-        <Menu mode="horizontal" :active-name="selectedMenu" style="position: absolute;top: 0;right: 0;">
-            <MenuItem name="home" to="/">首页</MenuItem>
-            <MenuItem name="docs" to="/docs" target="_blank">
-                文档
-            </MenuItem>
-            <MenuItem name="console" to="console">
-                控制台
-            </MenuItem>
-            <Submenu name="plugins">
-                <template slot="title">
-                    内置插件
-                </template>
-                <MenuGroup title="发布者/订阅者">
-                    <MenuItem name="cluster" to="/docs/plugins.html#cluster插件">集群</MenuItem>
-                    <MenuItem name="rtmp" to="/docs/plugins.html#rtmp插件">RTMP</MenuItem>
-                </MenuGroup>
-                <MenuGroup title="订阅者">
-                    <MenuItem name="jessica" to="/docs/plugins.html#jessica插件">Jessica</MenuItem>
-                    <MenuItem name="HDL" to="/docs/plugins.html#http-flv插件">Http-Flv</MenuItem>
-                    <MenuItem name="record" to="/docs/plugins.html#recordflv插件">录制Flv</MenuItem>
-                </MenuGroup>
-                <MenuGroup title="发布者">
-                    <MenuItem name="HLS" to="/docs/plugins.html#hls插件">HLS</MenuItem>
-                    <MenuItem name="TS" to="/docs/plugins.html#hls插件">TS</MenuItem>
-                </MenuGroup>
-                <MenuGroup title="钩子">
-                    <MenuItem name="Auth" to="/docs/plugins.html#校验插件">验证</MenuItem>
-                    <MenuItem name="QoS">QoS</MenuItem>
-                    <MenuItem name="gateway" to="/docs/plugins.html#网关插件">网关</MenuItem>
-                </MenuGroup>
-            </Submenu>
-            <MenuItem name="4" to="about">
-                支持
-            </MenuItem>
-        </Menu>
-        <router-view class="content"></router-view>
-        <div>Copyright © 2019-2020 dexter 苏ICP备20001212号</div>
-    </div>
+  <div id="app">
+    <div>Monibuca</div>
+    <Menu mode="horizontal" :active-name="selectedMenu" style="position: absolute;top: 0;right: 0;">
+      <MenuItem name="home" to="/">首页</MenuItem>
+      <MenuItem name="docs" to="/docs" target="_blank">文档</MenuItem>
+      <MenuItem name="console" to="console">控制台</MenuItem>
+      <Submenu name="plugins">
+        <template slot="title">内置插件</template>
+        <MenuGroup title="发布者/订阅者">
+          <MenuItem name="cluster" target="_blank" to="/docs/plugins.html#cluster插件">集群</MenuItem>
+          <MenuItem name="rtmp" target="_blank" to="/docs/plugins.html#rtmp插件">RTMP</MenuItem>
+        </MenuGroup>
+        <MenuGroup title="订阅者">
+          <MenuItem name="jessica" target="_blank" to="/docs/plugins.html#jessica插件">Jessica</MenuItem>
+          <MenuItem name="HDL" target="_blank" to="/docs/plugins.html#http-flv插件">Http-Flv</MenuItem>
+          <MenuItem name="record" target="_blank" to="/docs/plugins.html#recordflv插件">录制Flv</MenuItem>
+        </MenuGroup>
+        <MenuGroup title="发布者">
+          <MenuItem name="HLS" target="_blank" to="/docs/plugins.html#hls插件">HLS</MenuItem>
+          <MenuItem name="TS" target="_blank" to="/docs/plugins.html#hls插件">TS</MenuItem>
+        </MenuGroup>
+        <MenuGroup title="钩子">
+          <MenuItem name="Auth" target="_blank" to="/docs/plugins.html#校验插件">验证</MenuItem>
+          <MenuItem name="QoS">QoS</MenuItem>
+          <MenuItem name="gateway" target="_blank" to="/docs/plugins.html#网关插件">网关</MenuItem>
+        </MenuGroup>
+      </Submenu>
+      <MenuItem name="4" to="about">支持</MenuItem>
+    </Menu>
+    <router-view class="content"></router-view>
+    <div>Copyright © 2019-2020 dexter 苏ICP备20001212号</div>
+  </div>
 </template>
 
 <script>
-
-    export default {
-        name: 'app',
-        data(){
-            return {
-                selectedMenu:"home"
-            }
-        }
-    }
+export default {
+  name: "app",
+  data() {
+    return {
+      selectedMenu: "home"
+    };
+  }
+};
 </script>
 
 <style>
-    body,html{
-        height: 100%;
-    }
-    #app {
-        font-family: 'Avenir', Helvetica, Arial, sans-serif;
-        -webkit-font-smoothing: antialiased;
-        -moz-osx-font-smoothing: grayscale;
-        text-align: center;
-        color: #184c18;
-        position: relative;
-        height: 100%;
-    }
+body,
+html {
+  height: 100%;
+}
+#app {
+  font-family: "Avenir", Helvetica, Arial, sans-serif;
+  -webkit-font-smoothing: antialiased;
+  -moz-osx-font-smoothing: grayscale;
+  text-align: center;
+  color: #184c18;
+  position: relative;
+  height: 100%;
+}
 
-
-    #app > div:first-child {
-        position: absolute;
-        top: 10px;
-        left: 30px;
-        font-size: x-large;
-    }
-    .content{
-        padding-top: 60px;
-    }
+#app > div:first-child {
+  position: absolute;
+  top: 10px;
+  left: 30px;
+  font-size: x-large;
+}
+.content {
+  padding-top: 60px;
+}
 </style>

dashboard/src/components/Cluster.vue

@@ -0,0 +1,106 @@
+<template>
+  <div>
+    自动更新
+    <i-switch v-model="autoUpdate"></i-switch>
+    <div id="mountNode"></div>
+  </div>
+</template>
+
+<script>
+import { mapState } from "vuex";
+import G6 from "@antv/g6";
+var graph = null;
+export default {
+  data() {
+    return {
+      autoUpdate: true
+    };
+  },
+  computed: {
+    ...mapState({
+      data(state) {
+        let d = this.addServer(state.summary);
+        d.label = "🏠" + d.label;
+        return d;
+      }
+    })
+  },
+  methods: {
+    addServer(node) {
+      let result = {
+        id: node.Address,
+        label: node.Address,
+        description: `cpu:${node.CPUUsage >> 0}% mem:${node.Memory.Usage >>
+          0}%`,
+        shape: "modelRect",
+        logoIcon: {
+          show: false
+        },
+        children: []
+      };
+
+      if (node.Rooms) {
+        for (let i = 0; i < node.Rooms.length; i++) {
+          let room = node.Rooms[i];
+          let roomId = room.StreamPath;
+          let roomData = {
+            id: roomId,
+            label: room.StreamPath,
+            shape: "rect",
+            children: []
+          };
+          result.children.push(roomData);
+          if (room.SubscriberInfo) {
+            for (let j = 0; j < room.SubscriberInfo.length; j++) {
+              let subId = roomId + room.SubscriberInfo[j].ID;
+              roomData.children.push({
+                id: subId,
+                label: room.SubscriberInfo[j].ID
+              });
+            }
+          }
+        }
+      }
+      if (node.Children) {
+        for (let childId in node.Children) {
+          result.children.push(this.addServer(node.Children[childId]));
+        }
+      }
+      return result;
+    }
+  },
+  watch: {
+    data(v) {
+      if (graph && this.autoUpdate) {
+        //graph.updateChild(v, "");
+        graph.changeData(v); // 加载数据
+        graph.fitView();
+        //graph.read(v);
+      }
+    }
+  },
+  mounted() {
+    graph = new G6.TreeGraph({
+      linkCenter: true,
+      // renderer: "svg",
+      container: "mountNode", // 指定挂载容器
+      width: 800, // 图的宽度
+      height: 500, // 图的高度
+      modes: {
+        default: ["drag-canvas", "zoom-canvas", "click-select", "drag-node"]
+      },
+      animate: false,
+      layout: {
+        // type: "indeted",
+        direction: "H"
+      }
+    });
+    //graph.addChild(this.data, "");
+    graph.read(this.data); // 加载数据
+    graph.fitView();
+  }
+};
+</script>
+
+<style>
+</style>

dashboard/src/components/Config.vue

@@ -1,9 +1,7 @@
 <template>
-  <Modal v-bind="$attrs" draggable v-on="$listeners" @on-visible-change="onVisible" title="配置">
-    <div>
-      <pre>{{config}}</pre>
-    </div>
-  </Modal>
+  <div style="padding:0 15px">
+    <pre>{{config}}</pre>
+  </div>
 </template>
 
 <script>

dashboard/src/components/Jessibuca.vue

@@ -1,50 +1,67 @@
 <template>
-    <Modal
-            v-bind="$attrs" draggable
-            v-on="$listeners"
-            :title="url"
-            @on-ok="onClosePreview"
-            @on-cancel="onClosePreview">
-        <canvas id="canvas" width="488" height="275" style="background: black"/>
-    </Modal>
+  <Modal
+    v-bind="$attrs"
+    draggable
+    v-on="$listeners"
+    :title="url"
+    @on-ok="onClosePreview"
+    @on-cancel="onClosePreview"
+  >
+    <canvas id="canvas" width="488" height="275" style="background: black" />
+    <div slot="footer">
+      音频缓冲：
+      <InputNumber v-model="audioBuffer" size="small"></InputNumber>
+      <Button v-if="audioEnabled" @click="turnOff" icon="md-volume-off" />
+      <Button v-else @click="turnOn" icon="md-volume-up"></Button>
+    </div>
+  </Modal>
 </template>
 
 <script>
-    let h5lc = null;
-    export default {
-        name: 'Jessibuca',
-        props: {
-            audioEnabled: Boolean,
-        },
-        data(){
-            return {
-                url:""
-            }
-        },
-        watch: {
-            audioEnabled(value){
-              h5lc.audioEnabled(value)
-            }
-        },
-        mounted() {
-            h5lc = new window.Jessibuca({
-                canvas: document.getElementById("canvas"),
-                decoder: "jessibuca/ff.js"
-            });
-        },
-        destroyed() {
-            this.onClosePreview()
-            h5lc.destroy()
-        },
-        methods: {
-            play(url){
-                this.url = url
-                h5lc.play(url)
-            },
-            onClosePreview() {
-                h5lc.close();
-            },
-        }
+let h5lc = null;
+export default {
+  name: "Jessibuca",
+  data() {
+    return {
+      audioEnabled: false,
+      audioBuffer: 12,
+      url: ""
+    };
+  },
+  watch: {
+    audioEnabled(value) {
+      h5lc.audioEnabled(value);
+    },
+    audioBuffer(v) {
+      h5lc.audioBuffer = v;
     }
+  },
+  mounted() {
+    h5lc = new window.Jessibuca({
+      canvas: document.getElementById("canvas"),
+      decoder: "jessibuca/ff.js",
+      audioBuffer: this.audioBuffer
+    });
+  },
+  destroyed() {
+    this.onClosePreview();
+    h5lc.destroy();
+  },
+  methods: {
+    play(url) {
+      this.url = url;
+      h5lc.play(url);
+    },
+    onClosePreview() {
+      h5lc.close();
+    },
+    turnOn() {
+      this.audioEnabled = true;
+    },
+    turnOff() {
+      this.audioEnabled = false;
+    }
+  }
+};
 </script>
 

dashboard/src/components/Logs.vue

@@ -1,13 +1,13 @@
 <template>
-  <Modal v-bind="$attrs" draggable v-on="$listeners" @on-visible-change="onVisible" title="日志跟踪">
-    <div ref="logContainer" class="log-container">
-      <pre><template v-for="item in $store.state.logs">{{item+"\n"}}</template></pre>
-    </div>
-    <div slot="footer">
+  <div style="padding:0 15px">
+    <div>
       自动滚动
       <Switch v-model="autoScroll" />
     </div>
-  </Modal>
+    <div ref="logContainer" class="log-container">
+      <pre><template v-for="item in $store.state.logs">{{item+"\n"}}</template></pre>
+    </div>
+  </div>
 </template>
 
 <script>
@@ -18,15 +18,14 @@ export default {
       autoScroll: true
     };
   },
+  mounted() {
+    this.fetchLogs();
+  },
+  destroyed() {
+    this.stopFetchLogs();
+  },
   methods: {
-    ...mapActions(["fetchLogs", "stopFetchLogs"]),
-    onVisible(visible) {
-      if (visible) {
-        this.fetchLogs();
-      } else {
-        this.stopFetchLogs();
-      }
-    }
+    ...mapActions(["fetchLogs", "stopFetchLogs"])
   },
   updated() {
     if (this.autoScroll) {
@@ -39,6 +38,6 @@ export default {
 <style>
 .log-container {
   overflow-y: auto;
-  max-height: 360px;
+  max-height: 500px;
 }
 </style>

dashboard/src/components/Records.vue

@@ -1,21 +1,14 @@
 <template>
-  <Modal v-bind="$attrs" draggable v-on="$listeners" title="录制的视频"  @on-visible-change="onVisible" :z-index="900">
-    <List>
-      <ListItem v-for="item in data" :key="item">
-        <ListItemMeta :title="item.Path">
-          <template slot="description">{{toSizeStr(item.Size)}} {{toDurationStr(item.Duration)}}</template>
-        </ListItemMeta>
-        <template slot="action">
-          <li>
-            <a href="javascript:void(0)" @click="play(item)">Play</a>
-          </li>
-          <li>
-            <a href="javascript:void(0)" @click="deleteFlv(item)">Delete</a>
-          </li>
-        </template>
-      </ListItem>
-    </List>
-  </Modal>
+  <div class="records">
+    <Card v-for="item in data" :key="item">
+      <p slot="title">{{item.Path}}</p>
+      <div slot="extra">
+        <Button @click="play(item)" icon="md-play" size="small"></Button>
+        <Button @click="deleteFlv(item)" icon="ios-trash" size="small"></Button>
+      </div>
+      {{toSizeStr(item.Size)}} {{toDurationStr(item.Duration)}}
+    </Card>
+  </div>
 </template>
 
 <script>
@@ -39,8 +32,8 @@ export default {
         { streamPath: item.Path.replace(".flv", "") },
         x => {
           if (x == "success") {
-            this.onVisible(true)
-            this.$Message.success("删除成功");
+            this.onVisible(true);
+            this.$Message.success("开始发布");
           } else {
             this.$Message.error(x);
           }
@@ -57,7 +50,7 @@ export default {
             { streamPath: item.Path.replace(".flv", "") },
             x => {
               if (x == "success") {
-                this.$Message.success("开始发布");
+                this.$Message.success("删除成功");
               } else {
                 this.$Message.error(x);
               }
@@ -92,14 +85,14 @@ export default {
         return value + "ms";
       }
     },
-    onVisible(visible){
-      if(visible){
+    onVisible(visible) {
+      if (visible) {
         window.ajax.getJSON(
-                "//" + location.host + "/api/record/flv/list",
-                {},
-                x => {
-                  this.data = x;
-                }
+          "//" + location.host + "/api/record/flv/list",
+          {},
+          x => {
+            this.data = x;
+          }
         );
       }
     }
@@ -107,5 +100,13 @@ export default {
 };
 </script>
 
-<style>
+<style scoped>
+.records {
+  display: flex;
+  flex-wrap: wrap;
+  padding: 0 15px;
+}
+.records > * {
+  width: 200px;
+}
 </style>

dashboard/src/components/Subscribers.vue

@@ -0,0 +1,62 @@
+<template>
+  <Modal v-bind="$attrs" draggable v-on="$listeners" title="查看订阅者">
+    <Table :columns="subtableColumns" :data="data"></Table>
+  </Modal>
+</template>
+
+<script>
+export default {
+  props: {
+    data: Array
+  },
+  data() {
+    return {
+      subtableColumns: [
+        {
+          title: "类型",
+          key: "Type"
+        },
+        {
+          title: "Name",
+          key: "ID"
+        },
+        {
+          title: "订阅时间",
+          render(h, { row }) {
+            return h("StartTime", {
+              props: {
+                value: row.SubscribeTime
+              }
+            });
+          }
+        },
+        {
+          title: "丢帧",
+          render(h, { row }) {
+            return h(
+              "span",
+              row.TotalPacket ? row.TotalDrop + "/" + row.TotalPacket : ""
+            );
+          }
+        },
+        {
+          title: "Buffer",
+          render(h, { row }) {
+            return h("Progress", {
+              props: {
+                percent: Math.floor((row.BufferLength * 99) / 1024),
+                "text-inside": true,
+                "stroke-width": 20,
+                "stroke-color": ["#87d068", "#ff0000"]
+              }
+            });
+          }
+        }
+      ]
+    };
+  }
+};
+</script>
+
+<style>
+</style>

dashboard/src/store/index.js

@@ -7,6 +7,7 @@ let logsES = null
 export default new Vuex.Store({
   state: {
     summary: {
+      Address: location.hostname,
       NetWork: [],
       Rooms: [],
       Memory: {
@@ -17,7 +18,8 @@ export default new Vuex.Store({
       HardDisk: {
         Used: 0,
         Usage: 0
-      }
+      },
+      Children: {}
     }, logs: []
   },
   mutations: {
@@ -36,6 +38,7 @@ export default new Vuex.Store({
       summaryES.onmessage = evt => {
         if (!evt.data) return
         let summary = JSON.parse(evt.data)
+        summary.Address = location.hostname
         commit("update", { summary })
       }
     },

dashboard/src/views/Console.vue

@@ -1,273 +1,326 @@
 <template>
-    <div class="layout">
-        <ButtonGroup vertical>
-            <Button icon="ios-folder" @click="showRecords=true"></Button>
-            <Button icon="md-bug" @click="showLogs=true"></Button>
-            <Button icon="md-settings" @click="showConfig=true"></Button>
-        </ButtonGroup>
-        <Card v-for="item in Rooms" :key="item.StreamPath" class="room">
+  <div style="text-align:left;">
+    <Tabs v-model="currentTab" @on-click="onChangeTab">
+      <TabPane label="直播流" icon="md-videocam">
+        <div class="layout">
+          <Card v-for="item in Rooms" :key="item.StreamPath" class="room">
             <p slot="title">{{typeMap[item.Type]||item.Type}}{{item.StreamPath}}</p>
             <StartTime slot="extra" :value="item.StartTime"></StartTime>
             <p>
-                {{SoundFormat(item.AudioInfo.SoundFormat)}} {{item.AudioInfo.PacketCount}}
-                {{SoundRate(item.AudioInfo.SoundRate)}} 声道:{{item.AudioInfo.SoundType}}
+              {{SoundFormat(item.AudioInfo.SoundFormat)}} {{item.AudioInfo.PacketCount}}
+              {{SoundRate(item.AudioInfo.SoundRate)}} 声道:{{item.AudioInfo.SoundType}}
             </p>
             <p>
-                {{CodecID(item.VideoInfo.CodecID)}} {{item.VideoInfo.PacketCount}}
-                {{item.VideoInfo.SPSInfo.Width}}x{{item.VideoInfo.SPSInfo.Height}}
+              {{CodecID(item.VideoInfo.CodecID)}} {{item.VideoInfo.PacketCount}}
+              {{item.VideoInfo.SPSInfo.Width}}x{{item.VideoInfo.SPSInfo.Height}}
             </p>
             <ButtonGroup size="small">
-                <Button
-                        @click="onShowDetail(item)"
-                        icon="ios-people"
-                >{{item.SubscriberInfo?item.SubscriberInfo.length:0}}
-                </Button>
-                <Button v-if="item.Type" @click="preview(item)" icon="md-eye"></Button>
-                <Button
-                        @click="stopRecord(item)"
-                        class="recording"
-                        v-if="isRecording(item)"
-                        icon="ios-radio-button-on"
-                ></Button>
-                <Button @click="record(item)" v-else icon="ios-radio-button-on"></Button>
+              <Button @click="onShowDetail(item)" icon="ios-people">{{getSubscriberCount(item)}}</Button>
+              <Button v-if="item.Type" @click="preview(item)" icon="md-eye"></Button>
+              <Button
+                @click="stopRecord(item)"
+                class="recording"
+                v-if="isRecording(item)"
+                icon="ios-radio-button-on"
+              ></Button>
+              <Button @click="record(item)" v-else icon="ios-radio-button-on"></Button>
             </ButtonGroup>
-        </Card>
-        <div v-if="Rooms.length==0" class="empty">
-            <Icon type="md-wine" size="50"/>
-            没有任何房间
+          </Card>
+          <div v-if="Rooms.length==0" class="empty">
+            <Icon type="md-wine" size="50" />没有任何房间
+          </div>
         </div>
-        <div class="status">
-            <Alert>带宽消耗 📥：{{totalInNetSpeed}} 📤：{{totalOutNetSpeed}}</Alert>
-            <Alert
-                    :type="memoryStatus"
-            >内存使用：{{networkFormat(Memory.Used,"M")}} 占比：{{Memory.Usage.toFixed(2)}}%
-            </Alert>
-            <Alert :type="cpuStatus">CPU使用：{{CPUUsage.toFixed(2)}}%</Alert>
-            <Alert
-                    :type="hardDiskStatus"
-            >磁盘使用：{{networkFormat(HardDisk.Used,"M")}} 占比：{{HardDisk.Usage.toFixed(2)}}%
-            </Alert>
-        </div>
-        <Jessibuca ref="jessibuca" v-model="showPreview"></Jessibuca>
-        <Records v-model="showRecords"/>
-        <Logs v-model="showLogs"/>
-        <Config v-model="showConfig"/>
+      </TabPane>
+      <TabPane label="集群总览" icon="ios-cloud">
+        <Cluster />
+      </TabPane>
+      <TabPane label="录制的视频" icon="ios-folder" name="recordsPanel">
+        <Records ref="recordsPanel" />
+      </TabPane>
+      <TabPane label="日志跟踪" icon="md-bug">
+        <Logs />
+      </TabPane>
+      <TabPane label="查看配置" icon="md-settings" name="configPanel">
+        <Config ref="configPanel" />
+      </TabPane>
+    </Tabs>
+    <div class="status">
+      <Alert>带宽消耗 📥：{{totalInNetSpeed}} 📤：{{totalOutNetSpeed}}</Alert>
+      <Alert
+        :type="memoryStatus"
+      >内存使用：{{networkFormat(Memory.Used,"M")}} 占比：{{Memory.Usage.toFixed(2)}}%</Alert>
+      <Alert :type="cpuStatus">CPU使用：{{CPUUsage.toFixed(2)}}%</Alert>
+      <Alert
+        :type="hardDiskStatus"
+      >磁盘使用：{{networkFormat(HardDisk.Used,"M")}} 占比：{{HardDisk.Usage.toFixed(2)}}%</Alert>
     </div>
+    <Jessibuca ref="jessibuca" v-model="showPreview"></Jessibuca>
+    <Subscribers :data="currentStream && currentStream.SubscriberInfo" v-model="showSubscribers" />
+  </div>
 </template>
 
 <script>
-    import {mapActions, mapState} from "vuex";
-    import Jessibuca from "../components/Jessibuca";
-    import StartTime from "../components/StartTime";
-    import Records from "../components/Records";
-    import Logs from "../components/Logs";
-    import Config from "../components/Config"
-
-    const uintInc = {
-        "": "K",
-        K: "M",
-        M: "G",
-        G: null
+import { mapActions, mapState } from "vuex";
+import Jessibuca from "../components/Jessibuca";
+import StartTime from "../components/StartTime";
+import Records from "../components/Records";
+import Logs from "../components/Logs";
+import Config from "../components/Config";
+import Subscribers from "../components/Subscribers";
+import Cluster from "../components/Cluster";
+const uintInc = {
+  "": "K",
+  K: "M",
+  M: "G",
+  G: null
+};
+const SoundFormat = {
+  0: "Linear PCM, platform endian",
+  1: "ADPCM",
+  2: "MP3",
+  3: "Linear PCM, little endian",
+  4: "Nellymoser 16kHz mono",
+  5: "Nellymoser 8kHz mono",
+  6: "Nellymoser",
+  7: "G.711 A-law logarithmic PCM",
+  8: "G.711 mu-law logarithmic PCM",
+  9: "reserved",
+  10: "AAC",
+  11: "Speex",
+  14: "MP3 8Khz",
+  15: "Device-specific sound"
+};
+const CodecID = {
+  1: "JPEG (currently unused)",
+  2: "Sorenson H.263",
+  3: "Screen video",
+  4: "On2 VP6",
+  5: "On2 VP6 with alpha channel",
+  6: "Screen video version 2",
+  7: "AVC",
+  12: "H265"
+};
+export default {
+  name: "Console",
+  components: {
+    Jessibuca,
+    StartTime,
+    Records,
+    Logs,
+    Subscribers,
+    Config,
+    Cluster
+  },
+  data() {
+    return {
+      showPreview: false,
+      showSubscribers: false,
+      currentTab: "",
+      currentStream: [],
+      typeMap: {
+        Receiver: "📡",
+        FlvFile: "🎥",
+        TS: "🎬",
+        HLS: "🍎",
+        "": "⏳",
+        Match365: "🏆",
+        RTMP: "🚠"
+      }
     };
-    const SoundFormat = {
-        0: "Linear PCM, platform endian",
-        1: "ADPCM",
-        2: "MP3",
-        3: "Linear PCM, little endian",
-        4: "Nellymoser 16kHz mono",
-        5: "Nellymoser 8kHz mono",
-        6: "Nellymoser",
-        7: "G.711 A-law logarithmic PCM",
-        8: "G.711 mu-law logarithmic PCM",
-        9: "reserved",
-        10: "AAC",
-        11: "Speex",
-        14: "MP3 8Khz",
-        15: "Device-specific sound"
-    };
-    const CodecID = {
-        1: "JPEG (currently unused)",
-        2: "Sorenson H.263",
-        3: "Screen video",
-        4: "On2 VP6",
-        5: "On2 VP6 with alpha channel",
-        6: "Screen video version 2",
-        7: "AVC",
-        12: "H265"
-    };
-    export default {
-        name: "Console",
-        components: {
-            Jessibuca,
-            StartTime,
-            Records,
-            Logs, Config
-        },
-        data() {
-            return {
-                showPreview: false,
-                showRecords: false,
-                showLogs: false,
-                showConfig: false,
-                typeMap: {
-                    FlvFile: "🎥",
-                    TS: "🎬",
-                    HLS: "🍎",
-                    "": "⏳",
-                    Match365: "🏆",
-                    RTMP: "🚠"
-                }
-            };
-        },
-        computed: {
-            ...mapState({
-                Rooms: state => state.summary.Rooms || [],
-                Memory: state => state.summary.Memory,
-                CPUUsage: state => state.summary.CPUUsage,
-                HardDisk: state => state.summary.HardDisk,
-                cpuStatus: state => {
-                    if (state.summary.CPUUsage > 99) return "error";
-                    return state.summary.CPUUsage > 50 ? "warning" : "success";
-                },
-                memoryStatus(state) {
-                    if (state.summary.CPUUsage > 99) return "error";
-                    return state.summary.CPUUsage > 50 ? "warning" : "success";
-                },
-                hardDiskStatus(state) {
-                    if (state.summary.CPUUsage > 99) return "error";
-                    return state.summary.CPUUsage > 50 ? "warning" : "success";
-                },
-                totalInNetSpeed(state) {
-                    return (
-                        this.networkFormat(
-                            state.summary.NetWork.reduce((aac, c) => aac + c.ReceiveSpeed, 0)
-                        ) + "/S"
-                    );
-                },
-                totalOutNetSpeed(state) {
-                    return (
-                        this.networkFormat(
-                            state.summary.NetWork.reduce((aac, c) => aac + c.SentSpeed, 0)
-                        ) + "/S"
-                    );
-                }
-            })
-        },
-        methods: {
-            ...mapActions(["fetchSummary", "stopFetchSummary"]),
-            preview(item) {
-                this.$refs.jessibuca.play(
-                    "ws://" + location.hostname + ":8080/" + item.StreamPath
-                );
-                this.showPreview = true;
-            },
-            onShowDetail() {
-                // this.showDetail = true
-                // this.currentSub = item
-            },
-            networkFormat(value, unit = "") {
-                if (value > 1024 && uintInc[unit]) {
-                    return this.networkFormat(value / 1024, uintInc[unit]);
-                }
-                return value.toFixed(2).replace(".00", "") + unit + "B";
-            },
-            SoundFormat(soundFormat) {
-                return SoundFormat[soundFormat];
-            },
-            CodecID(codec) {
-                return CodecID[codec];
-            },
-            SoundRate(rate) {
-                return rate > 1000 ? rate / 1000 + "kHz" : rate + "Hz";
-            },
-            record(item) {
-                window.ajax.get(
-                    "//" + location.host + "/api/record/flv",
-                    {streamPath: item.StreamPath},
-                    x => {
-                        if (x == "success") {
-                            this.$Message.success("开始录制");
-                        } else {
-                            this.$Message.error(x);
-                        }
-                    }
-                );
-            },
-            stopRecord(item) {
-                window.ajax.get(
-                    "//" + location.host + "/api/record/flv/stop",
-                    {streamPath: item.StreamPath},
-                    x => {
-                        if (x == "success") {
-                            this.$Message.success("停止录制");
-                        } else {
-                            this.$Message.error(x);
-                        }
-                    }
-                );
-            },
-            isRecording(item) {
-                return (
-                    item.SubscriberInfo &&
-                    item.SubscriberInfo.find(x => x.Type == "FlvRecord")
-                );
+  },
+  computed: {
+    ...mapState({
+      Rooms: state => state.summary.Rooms || [],
+      Memory: state => state.summary.Memory,
+      CPUUsage: state => state.summary.CPUUsage,
+      HardDisk: state => state.summary.HardDisk,
+      cpuStatus: state => {
+        if (state.summary.CPUUsage > 99) return "error";
+        return state.summary.CPUUsage > 50 ? "warning" : "success";
+      },
+      memoryStatus(state) {
+        if (state.summary.CPUUsage > 99) return "error";
+        return state.summary.CPUUsage > 50 ? "warning" : "success";
+      },
+      hardDiskStatus(state) {
+        if (state.summary.CPUUsage > 99) return "error";
+        return state.summary.CPUUsage > 50 ? "warning" : "success";
+      },
+      totalInNetSpeed(state) {
+        return (
+          this.networkFormat(
+            state.summary.NetWork
+              ? state.summary.NetWork.reduce(
+                  (aac, c) => aac + c.ReceiveSpeed,
+                  0
+                )
+              : 0
+          ) + "/S"
+        );
+      },
+      totalOutNetSpeed(state) {
+        return (
+          this.networkFormat(
+            state.summary.NetWork
+              ? state.summary.NetWork.reduce((aac, c) => aac + c.SentSpeed, 0)
+              : 0
+          ) + "/S"
+        );
+      }
+    })
+  },
+  methods: {
+    ...mapActions(["fetchSummary", "stopFetchSummary"]),
+    getSubscriberCount(item) {
+      if (
+        this.currentStream &&
+        this.currentStream.StreamPath == item.StreamPath
+      ) {
+        this.currentStream = item;
+      }
+      return item.SubscriberInfo ? item.SubscriberInfo.length : 0;
+    },
+    preview(item) {
+      this.$refs.jessibuca.play(
+        "ws://" + location.hostname + ":8080/" + item.StreamPath
+      );
+      this.showPreview = true;
+    },
+    onShowDetail(item) {
+      this.showSubscribers = true;
+      this.currentStream = item;
+    },
+    networkFormat(value, unit = "") {
+      if (value > 1024 && uintInc[unit]) {
+        return this.networkFormat(value / 1024, uintInc[unit]);
+      }
+      return value.toFixed(2).replace(".00", "") + unit + "B";
+    },
+    SoundFormat(soundFormat) {
+      return SoundFormat[soundFormat];
+    },
+    CodecID(codec) {
+      return CodecID[codec];
+    },
+    SoundRate(rate) {
+      return rate > 1000 ? rate / 1000 + "kHz" : rate + "Hz";
+    },
+    record(item) {
+      this.$Modal.confirm({
+        title: "提示",
+        content: "<p>是否使用追加模式</p><small>选择取消将覆盖已有文件</small>",
+        onOk: () => {
+          window.ajax.get(
+            "//" + location.host + "/api/record/flv?append=true",
+            { streamPath: item.StreamPath },
+            x => {
+              if (x == "success") {
+                this.$Message.success("开始录制(追加模式)");
+              } else {
+                this.$Message.error(x);
+              }
             }
+          );
         },
-        mounted() {
-            this.fetchSummary();
-        },
-        destroyed() {
-            this.stopFetchSummary();
+        onCancel: () => {
+          window.ajax.get(
+            "//" + location.host + "/api/record/flv",
+            { streamPath: item.StreamPath },
+            x => {
+              if (x == "success") {
+                this.$Message.success("开始录制");
+              } else {
+                this.$Message.error(x);
+              }
+            }
+          );
         }
-    };
+      });
+    },
+    stopRecord(item) {
+      window.ajax.get(
+        "//" + location.host + "/api/record/flv/stop",
+        { streamPath: item.StreamPath },
+        x => {
+          if (x == "success") {
+            this.$Message.success("停止录制");
+          } else {
+            this.$Message.error(x);
+          }
+        }
+      );
+    },
+    isRecording(item) {
+      return (
+        item.SubscriberInfo &&
+        item.SubscriberInfo.find(x => x.Type == "FlvRecord")
+      );
+    },
+    onChangeTab(name) {
+      switch (name) {
+        case "recordsPanel":
+          this.$refs.recordsPanel.onVisible(true);
+          break;
+        case "configPanel":
+          this.$refs.configPanel.onVisible(true);
+      }
+    }
+  },
+  mounted() {
+    this.fetchSummary();
+  },
+  destroyed() {
+    this.stopFetchSummary();
+  }
+};
 </script>
 
 <style scoped>
-    @keyframes recording {
-        0% {
-            opacity: 0.2;
-        }
-        50% {
-            opacity: 1;
-        }
-        100% {
-            opacity: 0.2;
-        }
-    }
+@keyframes recording {
+  0% {
+    opacity: 0.2;
+  }
+  50% {
+    opacity: 1;
+  }
+  100% {
+    opacity: 0.2;
+  }
+}
 
-    .recording {
-        animation: recording 1s infinite;
-    }
+.recording {
+  animation: recording 1s infinite;
+}
 
-    .layout {
-        padding-bottom: 30px;
-        display: flex;
-        flex-wrap: wrap;
-    }
+.layout {
+  padding-bottom: 30px;
+  display: flex;
+  flex-wrap: wrap;
+}
 
-    .room {
-        width: 250px;
-        margin: 10px;
-        text-align: left;
-    }
+.room {
+  width: 250px;
+  margin: 10px;
+  text-align: left;
+}
 
-    .empty {
-        color: #eb5e46;
-        width: 100%;
-        min-height: 500px;
-        display: flex;
-        justify-content: center;
-        align-items: center;
-    }
+.empty {
+  color: #eb5e46;
+  width: 100%;
+  min-height: 500px;
+  display: flex;
+  justify-content: center;
+  align-items: center;
+}
 
-    .status {
-        position: fixed;
-        display: flex;
-        left: 5px;
-        bottom: 10px;
-    }
+.status {
+  position: fixed;
+  display: flex;
+  left: 5px;
+  bottom: 10px;
+}
 
-    .status > div {
-        margin: 0 5px;
-    }
+.status > div {
+  margin: 0 5px;
+}
 </style>

monica/hook.go

@@ -8,8 +8,8 @@ func (h AuthHook) AddHook(hook func(string) error) {
 	AuthHooks = append(h, hook)
 }
 func (h AuthHook) Trigger(sign string) error {
-	for _, h := range h {
-		if err := h(sign); err != nil {
+	for _, f := range h {
+		if err := f(sign); err != nil {
 			return err
 		}
 	}
@@ -24,8 +24,8 @@ func (h OnPublishHook) AddHook(hook func(r *Room)) {
 	OnPublishHooks = append(h, hook)
 }
 func (h OnPublishHook) Trigger(r *Room) {
-	for _, h := range h {
-		h(r)
+	for _, f := range h {
+		f(r)
 	}
 }
 
@@ -37,8 +37,8 @@ func (h OnSubscribeHook) AddHook(hook func(s *OutputStream)) {
 	OnSubscribeHooks = append(h, hook)
 }
 func (h OnSubscribeHook) Trigger(s *OutputStream) {
-	for _, h := range h {
-		h(s)
+	for _, f := range h {
+		f(s)
 	}
 }
 
@@ -50,7 +50,20 @@ func (h OnDropHook) AddHook(hook func(s *OutputStream)) {
 	OnDropHooks = append(h, hook)
 }
 func (h OnDropHook) Trigger(s *OutputStream) {
-	for _, h := range h {
-		h(s)
+	for _, f := range h {
+		f(s)
+	}
+}
+
+var OnSummaryHooks = make(OnSummaryHook, 0)
+
+type OnSummaryHook []func(bool)
+
+func (h OnSummaryHook) AddHook(hook func(bool)) {
+	OnSummaryHooks = append(h, hook)
+}
+func (h OnSummaryHook) Trigger(v bool) {
+	for _, f := range h {
+		f(v)
 	}
 }

monica/index.go

@@ -13,6 +13,7 @@ func Run(configFile string) (err error) {
 	if ConfigRaw, err = ioutil.ReadFile(configFile); err != nil {
 		return
 	}
+	go Summary.StartSummary()
 	if _, err = toml.Decode(string(ConfigRaw), cg); err == nil {
 		for name, config := range plugins {
 			if cfg, ok := cg.Plugins[name]; ok {

monica/room.go

@@ -2,11 +2,12 @@ package monica
 
 import (
 	"context"
-	"github.com/langhuihui/monibuca/monica/avformat"
-	"github.com/langhuihui/monibuca/monica/pool"
 	"log"
 	"sync"
 	"time"
+
+	"github.com/langhuihui/monibuca/monica/avformat"
+	"github.com/langhuihui/monibuca/monica/pool"
 )
 
 var (
@@ -111,11 +112,13 @@ func (r *Room) Run() {
 		case <-r.Done():
 			return
 		case <-update.C:
-			r.SubscriberInfo = make([]*SubscriberInfo, len(r.Subscribers))
-			i := 0
-			for _, v := range r.Subscribers {
-				r.SubscriberInfo[i] = &v.SubscriberInfo
-				i++
+			if Summary.Running() {
+				r.SubscriberInfo = make([]*SubscriberInfo, len(r.Subscribers))
+				i := 0
+				for _, v := range r.Subscribers {
+					r.SubscriberInfo[i] = &v.SubscriberInfo
+					i++
+				}
 			}
 		case s := <-r.Control:
 			switch v := s.(type) {
@@ -152,11 +155,17 @@ func (r *Room) Run() {
 	}
 }
 func (r *Room) PushAudio(audio *pool.AVPacket) {
+	if len(audio.Payload) < 3 {
+		return
+	}
 	if audio.Payload[0] == 0xFF && (audio.Payload[1]&0xF0) == 0xF0 {
 		audio.IsADTS = true
 		r.AudioTag = audio
 	} else if r.AudioTag == nil {
 		audio.IsAACSequence = true
+		if len(audio.Payload) < 5 {
+			return
+		}
 		r.AudioTag = audio
 		tmp := audio.Payload[0]                                                // 第一个字节保存着音频的相关信息
 		if r.AudioInfo.SoundFormat = tmp >> 4; r.AudioInfo.SoundFormat == 10 { //真的是AAC的话，后面有一个字节的详细信息
@@ -198,6 +207,9 @@ func (r *Room) setH264Info(video *pool.AVPacket) {
 	}
 }
 func (r *Room) PushVideo(video *pool.AVPacket) {
+	if len(video.Payload) < 3 {
+		return
+	}
 	video.VideoFrameType = video.Payload[0] >> 4  // 帧类型 4Bit, H264一般为1或者2
 	r.VideoInfo.CodecID = video.Payload[0] & 0x0f // 编码类型ID 4Bit, JPEG, H263, AVC...
 	video.IsAVCSequence = video.VideoFrameType == 1 && video.Payload[1] == 0

monica/summary.go

@@ -0,0 +1,142 @@
+package monica
+
+import (
+	"log"
+	"time"
+
+	"github.com/shirou/gopsutil/cpu"
+	"github.com/shirou/gopsutil/disk"
+	"github.com/shirou/gopsutil/mem"
+	"github.com/shirou/gopsutil/net"
+)
+
+var (
+	Summary = ServerSummary{}
+)
+
+type ServerSummary struct {
+	Address string
+	Memory  struct {
+		Total uint64
+		Free  uint64
+		Used  uint64
+		Usage float64
+	}
+	CPUUsage float64
+	HardDisk struct {
+		Total uint64
+		Free  uint64
+		Used  uint64
+		Usage float64
+	}
+	NetWork     []NetWorkInfo
+	Rooms       []*RoomInfo
+	lastNetWork []NetWorkInfo
+	ref         int
+	control     chan bool
+	reportChan  chan *ServerSummary
+	Children    map[string]*ServerSummary
+}
+type NetWorkInfo struct {
+	Name         string
+	Receive      uint64
+	Sent         uint64
+	ReceiveSpeed uint64
+	SentSpeed    uint64
+}
+
+func (s *ServerSummary) StartSummary() {
+	ticker := time.NewTicker(time.Second)
+	s.control = make(chan bool)
+	s.reportChan = make(chan *ServerSummary)
+	for {
+		select {
+		case <-ticker.C:
+			if s.ref > 0 {
+				Summary.collect()
+			}
+		case v := <-s.control:
+			if v {
+				if s.ref++; s.ref == 1 {
+					log.Println("start report summary")
+					OnSummaryHooks.Trigger(true)
+				}
+			} else {
+				if s.ref--; s.ref == 0 {
+					s.lastNetWork = nil
+					log.Println("stop report summary")
+					OnSummaryHooks.Trigger(false)
+				}
+			}
+		case report := <-s.reportChan:
+			s.Children[report.Address] = report
+		}
+	}
+}
+func (s *ServerSummary) Running() bool {
+	return s.ref > 0
+}
+func (s *ServerSummary) Add() {
+	s.control <- true
+}
+func (s *ServerSummary) Done() {
+	s.control <- false
+}
+func (s *ServerSummary) Report(slave *ServerSummary) {
+	s.reportChan <- slave
+}
+func (s *ServerSummary) collect() {
+	v, _ := mem.VirtualMemory()
+	//c, _ := cpu.Info()
+	cc, _ := cpu.Percent(time.Second, false)
+	d, _ := disk.Usage("/")
+	//n, _ := host.Info()
+	nv, _ := net.IOCounters(true)
+	//boottime, _ := host.BootTime()
+	//btime := time.Unix(int64(boottime), 0).Format("2006-01-02 15:04:05")
+	s.Memory.Total = v.Total / 1024 / 1024
+	s.Memory.Free = v.Available / 1024 / 1024
+	s.Memory.Used = v.Used / 1024 / 1024
+	s.Memory.Usage = v.UsedPercent
+	//fmt.Printf("        Mem       : %v MB  Free: %v MB Used:%v Usage:%f%%\n", v.Total/1024/1024, v.Available/1024/1024, v.Used/1024/1024, v.UsedPercent)
+	//if len(c) > 1 {
+	//	for _, sub_cpu := range c {
+	//		modelname := sub_cpu.ModelName
+	//		cores := sub_cpu.Cores
+	//		fmt.Printf("        CPU       : %v   %v cores \n", modelname, cores)
+	//	}
+	//} else {
+	//	sub_cpu := c[0]
+	//	modelname := sub_cpu.ModelName
+	//	cores := sub_cpu.Cores
+	//	fmt.Printf("        CPU       : %v   %v cores \n", modelname, cores)
+	//}
+	s.CPUUsage = cc[0]
+	s.HardDisk.Free = d.Free / 1024 / 1024 / 1024
+	s.HardDisk.Total = d.Total / 1024 / 1024 / 1024
+	s.HardDisk.Used = d.Used / 1024 / 1024 / 1024
+	s.HardDisk.Usage = d.UsedPercent
+	s.NetWork = make([]NetWorkInfo, len(nv))
+	for i, n := range nv {
+		s.NetWork[i].Name = n.Name
+		s.NetWork[i].Receive = n.BytesRecv
+		s.NetWork[i].Sent = n.BytesSent
+		if s.lastNetWork != nil && len(s.lastNetWork) > i {
+			s.NetWork[i].ReceiveSpeed = n.BytesRecv - s.lastNetWork[i].Receive
+			s.NetWork[i].SentSpeed = n.BytesSent - s.lastNetWork[i].Sent
+		}
+	}
+	s.lastNetWork = s.NetWork
+	//fmt.Printf("        Network: %v bytes / %v bytes\n", nv[0].BytesRecv, nv[0].BytesSent)
+	//fmt.Printf("        SystemBoot:%v\n", btime)
+	//fmt.Printf("        CPU Used    : used %f%% \n", cc[0])
+	//fmt.Printf("        HD        : %v GB  Free: %v GB Usage:%f%%\n", d.Total/1024/1024/1024, d.Free/1024/1024/1024, d.UsedPercent)
+	//fmt.Printf("        OS        : %v(%v)   %v  \n", n.Platform, n.PlatformFamily, n.PlatformVersion)
+	//fmt.Printf("        Hostname  : %v  \n", n.Hostname)
+	s.Rooms = nil
+	AllRoom.Range(func(key interface{}, v interface{}) bool {
+		s.Rooms = append(s.Rooms, &v.(*Room).RoomInfo)
+		return true
+	})
+	return
+}

plugins/HLS/m3u8.go

@@ -4,14 +4,15 @@ import (
 	"bytes"
 	"compress/gzip"
 	"context"
-	. "github.com/langhuihui/monibuca/monica"
-	"github.com/quangngotan95/go-m3u8/m3u8"
 	"io"
 	"io/ioutil"
 	"log"
 	"net/http"
 	"path/filepath"
 	"time"
+
+	. "github.com/langhuihui/monibuca/monica"
+	"github.com/quangngotan95/go-m3u8/m3u8"
 )
 
 type HLS struct {
@@ -94,8 +95,8 @@ func (p *HLS) run(info *M3u8Info) {
 			if len(tsItems) > 3 {
 				tsItems = tsItems[len(tsItems)-3:]
 			}
-			info.M3u8Info = make([]TSCost, len(tsItems))
-			for i, v := range tsItems {
+			info.M3u8Info = nil
+			for _, v := range tsItems {
 				tsCost := TSCost{}
 				tsUrl, _ := info.Req.URL.Parse(v.Segment)
 				tsReq, _ := http.NewRequest("GET", tsUrl.String(), nil)
@@ -122,7 +123,7 @@ func (p *HLS) run(info *M3u8Info) {
 				} else if err != nil {
 					log.Printf("%s reqTs:%v", p.StreamPath, err)
 				}
-				info.M3u8Info[i] = tsCost
+				info.M3u8Info = append(info.M3u8Info, tsCost)
 			}
 
 			time.Sleep(time.Second * time.Duration(playlist.Target) * 2)

plugins/cluster/index.go

@@ -1,8 +1,16 @@
 package cluster
 
 import (
-	. "github.com/langhuihui/monibuca/monica"
+	"bufio"
+	"encoding/json"
+	"io"
 	"log"
+	"math/rand"
+	"net"
+	"sync"
+	"time"
+
+	. "github.com/langhuihui/monibuca/monica"
 )
 
 const (
@@ -11,12 +19,18 @@ const (
 	MSG_VIDEO
 	MSG_SUBSCRIBE
 	MSG_AUTH
+	MSG_SUMMARY
+	MSG_LOG
 )
 
-var config = struct {
-	Master     string
-	ListenAddr string
-}{}
+var (
+	config = struct {
+		Master     string
+		ListenAddr string
+	}{}
+	slaves     = sync.Map{}
+	masterConn *net.TCPConn
+)
 
 func init() {
 	InstallPlugin(&PluginConfig{
@@ -29,13 +43,85 @@ func init() {
 func run() {
 	if config.Master != "" {
 		OnSubscribeHooks.AddHook(onSubscribe)
+		addr, err := net.ResolveTCPAddr("tcp", config.Master)
+		if MayBeError(err) {
+			return
+		}
+		go readMaster(addr)
 	}
 	if config.ListenAddr != "" {
+		Summary.Children = make(map[string]*ServerSummary)
+		OnSummaryHooks.AddHook(onSummary)
 		log.Printf("server bare start at %s", config.ListenAddr)
 		log.Fatal(ListenBare(config.ListenAddr))
 	}
 }
 
+func readMaster(addr *net.TCPAddr) {
+	var err error
+	var cmd byte
+	for {
+		if masterConn, err = net.DialTCP("tcp", nil, addr); !MayBeError(err) {
+			reader := bufio.NewReader(masterConn)
+			log.Printf("connect to master %s reporting", config.Master)
+			for report(); err == nil; {
+				if cmd, err = reader.ReadByte(); !MayBeError(err) {
+					switch cmd {
+					case MSG_SUMMARY: //收到主服务器指令，进行采集和上报
+						log.Println("receive summary request from master")
+						if cmd, err = reader.ReadByte(); !MayBeError(err) {
+							if cmd == 1 {
+								Summary.Add()
+								go onReport()
+							} else {
+								Summary.Done()
+							}
+						}
+					}
+				}
+			}
+		}
+		t := 5 + rand.Int63n(5)
+		log.Printf("reconnect to master %s after %d seconds", config.Master, t)
+		time.Sleep(time.Duration(t) * time.Second)
+	}
+}
+func report() {
+	if b, err := json.Marshal(Summary); err == nil {
+		data := make([]byte, len(b)+2)
+		data[0] = MSG_SUMMARY
+		copy(data[1:], b)
+		data[len(data)-1] = 0
+		_, err = masterConn.Write(data)
+	}
+}
+
+//定时上报
+func onReport() {
+	for range time.NewTicker(time.Second).C {
+		if Summary.Running() {
+			report()
+		} else {
+			return
+		}
+	}
+}
+func orderReport(conn io.Writer, start bool) {
+	b := []byte{MSG_SUMMARY, 0}
+	if start {
+		b[1] = 1
+	}
+	conn.Write(b)
+}
+
+//通知从服务器需要上报或者关闭上报
+func onSummary(start bool) {
+	slaves.Range(func(k, v interface{}) bool {
+		orderReport(v.(*net.TCPConn), start)
+		return true
+	})
+}
+
 func onSubscribe(s *OutputStream) {
 	if s.Publisher == nil {
 		go PullUpStream(s.StreamPath)

plugins/cluster/publisher.go

@@ -3,12 +3,14 @@ package cluster
 import (
 	"bufio"
 	"encoding/binary"
+	"io"
+	"log"
+	"net"
+	"strings"
+
 	. "github.com/langhuihui/monibuca/monica"
 	"github.com/langhuihui/monibuca/monica/avformat"
 	"github.com/langhuihui/monibuca/monica/pool"
-	"io"
-	"net"
-	"strings"
 )
 
 type Receiver struct {
@@ -26,6 +28,7 @@ func (p *Receiver) Auth(authSub *OutputStream) {
 
 func (p *Receiver) readAVPacket(avType byte) (av *pool.AVPacket, err error) {
 	buf := pool.GetSlice(4)
+	defer pool.RecycleSlice(buf)
 	_, err = io.ReadFull(p, buf)
 	if err != nil {
 		println(err.Error())
@@ -39,12 +42,10 @@ func (p *Receiver) readAVPacket(avType byte) (av *pool.AVPacket, err error) {
 	}
 	av.Payload = pool.GetSlice(int(binary.BigEndian.Uint32(buf)))
 	_, err = io.ReadFull(p, av.Payload)
-	if MayBeError(err) {
-		return
-	}
-	pool.RecycleSlice(buf)
+	MayBeError(err)
 	return
 }
+
 func PullUpStream(streamPath string) {
 	addr, err := net.ResolveTCPAddr("tcp", config.Master)
 	if MayBeError(err) {
@@ -56,7 +57,7 @@ func PullUpStream(streamPath string) {
 	}
 	brw := bufio.NewReadWriter(bufio.NewReader(conn), bufio.NewWriter(conn))
 	p := &Receiver{
-		Reader: conn,
+		Reader: brw.Reader,
 		Writer: brw.Writer,
 	}
 	if p.Publish(streamPath, p) {
@@ -71,11 +72,7 @@ func PullUpStream(streamPath string) {
 		return
 	}
 	defer p.Cancel()
-	for {
-		cmd, err := brw.ReadByte()
-		if MayBeError(err) {
-			return
-		}
+	for cmd, err := brw.ReadByte(); !MayBeError(err); cmd, err = brw.ReadByte() {
 		switch cmd {
 		case MSG_AUDIO:
 			if audio, err := p.readAVPacket(avformat.FLV_TAG_TYPE_AUDIO); err == nil {
@@ -102,6 +99,8 @@ func PullUpStream(streamPath string) {
 					v.Cancel()
 				}
 			}
+		default:
+			log.Printf("unknown cmd:%v", cmd)
 		}
 	}
 }

plugins/cluster/subscriber.go

@@ -3,13 +3,16 @@ package cluster
 import (
 	"bufio"
 	"encoding/binary"
+	"encoding/json"
 	"fmt"
-	. "github.com/langhuihui/monibuca/monica"
-	"github.com/langhuihui/monibuca/monica/pool"
+	"io"
 	"net"
 	"strconv"
 	"strings"
 	"time"
+
+	. "github.com/langhuihui/monibuca/monica"
+	"github.com/langhuihui/monibuca/monica/pool"
 )
 
 func ListenBare(addr string) error {
@@ -49,6 +52,7 @@ func ListenBare(addr string) error {
 func process(conn net.Conn) {
 	defer conn.Close()
 	reader := bufio.NewReader(conn)
+	connAddr := conn.RemoteAddr().String()
 	stream := OutputStream{
 		SendHandler: func(p *pool.SendPacket) error {
 			head := pool.GetSlice(9)
@@ -64,7 +68,7 @@ func process(conn net.Conn) {
 			}
 			return nil
 		}, SubscriberInfo: SubscriberInfo{
-			ID:   conn.RemoteAddr().String(),
+			ID:   connAddr,
 			Type: "Bare",
 		},
 	}
@@ -73,31 +77,39 @@ func process(conn net.Conn) {
 		if err != nil {
 			return
 		}
+		bytes, err := reader.ReadBytes(0)
+		if err != nil {
+			return
+		}
+		bytes = bytes[0 : len(bytes)-1]
 		switch cmd {
 		case MSG_SUBSCRIBE:
 			if stream.Room != nil {
 				fmt.Printf("bare stream already exist from %s", conn.RemoteAddr())
 				return
 			}
-			bytes, err := reader.ReadBytes(0)
-			if MayBeError(err) {
-				return
-			}
-			streamName := string(bytes[0 : len(bytes)-1])
-			stream.Play(streamName)
+			go stream.Play(string(bytes))
 		case MSG_AUTH:
-			bytes, err := reader.ReadBytes(0)
-			if err != nil {
-				print(err)
-				return
-			}
-			sign := strings.Split(string(bytes[0:len(bytes)-1]), ",")
-			head := []byte{MSG_AUTH, 0}
+			sign := strings.Split(string(bytes), ",")
+			head := []byte{MSG_AUTH, 2}
 			if len(sign) > 1 && AuthHooks.Trigger(sign[1]) == nil {
 				head[1] = 1
 			}
 			conn.Write(head)
-			conn.Write(bytes)
+			conn.Write(bytes[0 : len(bytes)+1])
+		case MSG_SUMMARY: //收到从服务器发来报告，加入摘要中
+			summary := &ServerSummary{}
+			if err = json.Unmarshal(bytes, summary); err == nil {
+				summary.Address = connAddr
+				Summary.Report(summary)
+				if _, ok := slaves.Load(connAddr); !ok {
+					slaves.Store(connAddr, conn)
+					if Summary.Running() {
+						orderReport(io.Writer(conn), true)
+					}
+					defer slaves.Delete(connAddr)
+				}
+			}
 		default:
 			fmt.Printf("bare receive unknown cmd:%d from %s", cmd, conn.RemoteAddr())
 			return

plugins/gateway/index.go

@@ -3,11 +3,6 @@ package gateway
 import (
 	"context"
 	"encoding/json"
-	. "github.com/langhuihui/monibuca/monica"
-	"github.com/shirou/gopsutil/cpu"
-	"github.com/shirou/gopsutil/disk"
-	"github.com/shirou/gopsutil/mem"
-	"github.com/shirou/gopsutil/net"
 	"io/ioutil"
 	"log"
 	"mime"
@@ -16,6 +11,8 @@ import (
 	"path"
 	"runtime"
 	"time"
+
+	. "github.com/langhuihui/monibuca/monica"
 )
 
 var (
@@ -133,93 +130,19 @@ func website(w http.ResponseWriter, r *http.Request) {
 }
 func summary(w http.ResponseWriter, r *http.Request) {
 	sse := NewSSE(w, r.Context())
-	s := collect()
-	sse.WriteJSON(&s)
-	for range time.NewTicker(time.Second).C {
-		old := s
-		s = collect()
-		for i, v := range s.NetWork {
-			s.NetWork[i].ReceiveSpeed = v.Receive - old.NetWork[i].Receive
-			s.NetWork[i].SentSpeed = v.Sent - old.NetWork[i].Sent
-		}
-		AllRoom.Range(func(key interface{}, v interface{}) bool {
-			s.Rooms = append(s.Rooms, &v.(*Room).RoomInfo)
-			return true
-		})
-		if sse.WriteJSON(&s) != nil {
-			break
+	Summary.Add()
+	defer Summary.Done()
+	sse.WriteJSON(&Summary)
+	ticker := time.NewTicker(time.Second)
+	defer ticker.Stop()
+	for {
+		select {
+		case <-ticker.C:
+			if sse.WriteJSON(&Summary) != nil {
+				return
+			}
+		case <-r.Context().Done():
+			return
 		}
 	}
 }
-
-type Summary struct {
-	Memory struct {
-		Total uint64
-		Free  uint64
-		Used  uint64
-		Usage float64
-	}
-	CPUUsage float64
-	HardDisk struct {
-		Total uint64
-		Free  uint64
-		Used  uint64
-		Usage float64
-	}
-	NetWork []NetWorkInfo
-	Rooms   []*RoomInfo
-}
-type NetWorkInfo struct {
-	Name         string
-	Receive      uint64
-	Sent         uint64
-	ReceiveSpeed uint64
-	SentSpeed    uint64
-}
-
-func collect() (s Summary) {
-	v, _ := mem.VirtualMemory()
-	//c, _ := cpu.Info()
-	cc, _ := cpu.Percent(time.Second, false)
-	d, _ := disk.Usage("/")
-	//n, _ := host.Info()
-	nv, _ := net.IOCounters(true)
-	//boottime, _ := host.BootTime()
-	//btime := time.Unix(int64(boottime), 0).Format("2006-01-02 15:04:05")
-	s.Memory.Total = v.Total / 1024 / 1024
-	s.Memory.Free = v.Available / 1024 / 1024
-	s.Memory.Used = v.Used / 1024 / 1024
-	s.Memory.Usage = v.UsedPercent
-	//fmt.Printf("        Mem       : %v MB  Free: %v MB Used:%v Usage:%f%%\n", v.Total/1024/1024, v.Available/1024/1024, v.Used/1024/1024, v.UsedPercent)
-	//if len(c) > 1 {
-	//	for _, sub_cpu := range c {
-	//		modelname := sub_cpu.ModelName
-	//		cores := sub_cpu.Cores
-	//		fmt.Printf("        CPU       : %v   %v cores \n", modelname, cores)
-	//	}
-	//} else {
-	//	sub_cpu := c[0]
-	//	modelname := sub_cpu.ModelName
-	//	cores := sub_cpu.Cores
-	//	fmt.Printf("        CPU       : %v   %v cores \n", modelname, cores)
-	//}
-	s.CPUUsage = cc[0]
-	s.HardDisk.Free = d.Free / 1024 / 1024 / 1024
-	s.HardDisk.Total = d.Total / 1024 / 1024 / 1024
-	s.HardDisk.Used = d.Used / 1024 / 1024 / 1024
-	s.HardDisk.Usage = d.UsedPercent
-	s.NetWork = make([]NetWorkInfo, len(nv))
-	for i, n := range nv {
-		s.NetWork[i].Name = n.Name
-		s.NetWork[i].Receive = n.BytesRecv
-		s.NetWork[i].Sent = n.BytesSent
-	}
-
-	//fmt.Printf("        Network: %v bytes / %v bytes\n", nv[0].BytesRecv, nv[0].BytesSent)
-	//fmt.Printf("        SystemBoot:%v\n", btime)
-	//fmt.Printf("        CPU Used    : used %f%% \n", cc[0])
-	//fmt.Printf("        HD        : %v GB  Free: %v GB Usage:%f%%\n", d.Total/1024/1024/1024, d.Free/1024/1024/1024, d.UsedPercent)
-	//fmt.Printf("        OS        : %v(%v)   %v  \n", n.Platform, n.PlatformFamily, n.PlatformVersion)
-	//fmt.Printf("        Hostname  : %v  \n", n.Hostname)
-	return
-}

plugins/jessica/subscriber.go

@@ -2,12 +2,13 @@ package jessica
 
 import (
 	"encoding/binary"
+	"net/http"
+	"strings"
+
 	"github.com/gobwas/ws"
 	. "github.com/langhuihui/monibuca/monica"
 	"github.com/langhuihui/monibuca/monica/avformat"
 	"github.com/langhuihui/monibuca/monica/pool"
-	"net/http"
-	"strings"
 )
 
 func WsHandler(w http.ResponseWriter, r *http.Request) {

slave.toml

@@ -0,0 +1,18 @@
+# [Plugins.HDL]
+# ListenAddr = ":2020"
+[Plugins.Jessica]
+ListenAddr = ":8082"
+[Plugins.RTMP]
+ListenAddr = ":1936"
+[Plugins.GateWay]
+ListenAddr = ":8083"
+[Plugins.Cluster]
+Master = "localhost:2019"
+#ListenAddr = ":2019"
+#
+#[Plugins.Auth]
+#Key="www.monibuca.com"
+# [Plugins.RecordFlv]
+# Path="./resource"
+# [Plugins.QoS]
+# Suffix = ["high","medium","low"]