CN103312799B - P2P communication means based on JXTA platform under environment of internet of things - Google Patents
P2P communication means based on JXTA platform under environment of internet of things Download PDFInfo
- Publication number
- CN103312799B CN103312799B CN201310214976.4A CN201310214976A CN103312799B CN 103312799 B CN103312799 B CN 103312799B CN 201310214976 A CN201310214976 A CN 201310214976A CN 103312799 B CN103312799 B CN 103312799B
- Authority
- CN
- China
- Prior art keywords
- node
- group
- privately owned
- node group
- jxtasoap
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Expired - Fee Related
Links
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
- Computer And Data Communications (AREA)
Abstract
The invention discloses P2P communication means based on JXTA platform under a kind of environment of internet of things, comprise the following steps: the JXTASocket agent node running on client connects default node group by JXTA network, and joins in described default node group；The JXTASoap agent node running on WEB server end connects default node group by JXTA network, and joins in described default node group；JXTASocket agent node in described client realizes P2P with the JXTASoap agent node in WEB server end in described default node group and communicates.JXTASocket agent node is connected in a node group by the present invention with JXTASoap agent node, carry out P2P communication, thus realize between node any under the conditions of interconnect, it is ensured that different industries information is fully mutual, different system information is mutually transmitted.
Description
Technical field
The present invention relates to Internet of Things communication means, put down based on JXTA in particular under a kind of environment of internet of things
The P2P communication means of platform.
Background technology
As emerging internet, Internet of Things achieves the interconnection between General Physics object.From thing
From the point of view of the development trend of networking, in order to realize Internet of Things value maximization, need various differences
Industry, the information of different system merge, thus promote the business valency of different industries and system
The innovation of value and restructuring.
And the first step realizing Internet of Things value maximization is exactly to need in existing article and the intelligence of equipment
Change and on the basis of digitlization, break through the barrier of information exchange.But, in actual applied field
Jing Zhong, deposits at the aspect such as hardware condition, software environment between the Internet of Things node of various different systems
In bigger otherness, as some Internet of Things node there is outer net IP address and some node only
The IP address of Intranet.Make the C/S(Client/ of information exchange conventional in original internet
Server) communication pattern and technology not always can be conveniently used in the interconnection of Internet of things node
In intercommunication.
Only realize between node any under the conditions of interconnect, guarantee different industries information
Fully mutual, different system information mutually pushes, fully excavate different industries, different system it
Between commercial value, thus embody Internet of Things be worth.It is therefore desirable to research a kind of Internet of Things joint
The point communication means interconnected in any condition.
Summary of the invention
It is an object of the invention to overcome above-mentioned the deficiencies in the prior art to provide under a kind of environment of internet of things
P2P communication means based on JXTA platform.
Realize the object of the invention to the technical scheme is that under a kind of environment of internet of things based on JXTA platform
P2P communication means, comprise the following steps:
The JXTASocket agent node running on client connects default node group by JXTA network,
And join in described default node group；
The JXTASoap agent node running on WEB server end connects default node group by JXTA network
, and join in described default node group；
JXTASocket agent node in described client and the JXTASoap agency in WEB server end
Node realizes P2P communication in described default node group.
The present invention will be located in the client in Internet of Things and WEB server end and forms one by JXTA network
P2P communication module, will JXTASocket agent node in client and JXT in JXTA network
The default node group of A server connects, by the JXTASoap agent node in WEB server also with
In JXTA network, the default node group of JXTA server connects, JXTASocket agent node and JX
TASoap agent node carries out P2P communication in default node group, thus realizes appointing between node
Interconnecting under the conditions of He, it is ensured that different industries information is fully mutual, different system information phase
Transmission mutually.
Accompanying drawing explanation
Fig. 1 is JXTA schematic network structure under environment of internet of things；
Fig. 2 is the flow chart of P2P communication means based on JXTA platform under environment of internet of things；
Fig. 3 is the workflow diagram of default node；
Fig. 4 is the workflow diagram of privately owned node；
Fig. 5 is the workflow diagram of JXTASocket agent node；
Fig. 6 is the workflow diagram of JXTASoap agent node.
Detailed description of the invention
The present invention is described in further detail with specific embodiment below in conjunction with the accompanying drawings.
As shown in Figure 1 and Figure 2, P2P communication means bag based on JXTA platform under environment of internet of things of the present invention
Include following steps:
Step S100, the JXTASocket agent node running on client is searched on JXTA network
Node group in JXTA server, and add in corresponding node group.
In the present embodiment, in JXTA server, operation has default node group, it is possible to as required silent
Recognize and node group is run privately owned node group further.Wherein, privately owned node group is provided with and recognizes safely
Card, in being used for protecting privately owned node group, resource, bulletin be not by external interference.Therefore this step tool
Body includes:
Step S101:JXTASocket agent node searches the default node group in JXTA server, and
It is connected with default node group.
Step S102: the privately owned node group connected as required, JXTASocket agent node is in acquiescence
Search corresponding privately owned node group according to privately owned node group name in node group, as searched, and lead to
After crossing safety certification, then it is connected with this privately owned node group, and joins in this privately owned node group.
Step S200, the JXTASoap agent node running on WEB server end is searched on JXTA network
Node group in JXTA server, and add in corresponding node group.
Same as above, if desired for adding corresponding privately owned node group, then specifically include:
Step S201:JXTASocket agent node searches the default node group set in JXTA server
Point S, and be connected with default node group.
Step S202: the privately owned node group connected as required, JXTASocket agent node is in acquiescence
Search corresponding privately owned node group according to privately owned node group name in node group, as searched, and lead to
After crossing safety certification, then it is connected with this privately owned node group, and joins in this privately owned node group.
Step S300:JXTASocket agent node and JXTASoap agent node are at privately owned node group collection
Chalaza A realizes P2P peer-to-peer communications, i.e. between the client on Internet of Things and WEB server
Form a kind of P2P communication.
As it is shown on figure 3, in the present embodiment step S100, node S creates default node in JXTA network
The meeting point of group NetPeerGroup, it is allowed to every other node adds acquiescence point by meeting point S
Group, its course of work is carried out the most successively:
Initialize journal file, empty node S cache file folder, configuration node S, startup JXTA platform
, add acquiescence point group a NetPeerGroup, obtain acquiescence point group a meeting point service, node is set
S is acquiescence point group meeting point, acquiescence point group meeting point event is monitored in circulation.
As shown in Figure 4, in the present embodiment step S200, node A is as node privately owned in JXTA network
The meeting point of group, it is allowed to other nodes add privately owned node group by meeting point A.It is worked
Journey is carried out the most successively:
Empty node S cache file folder, configuration node A, start JXTA platform, add acquiescence point group Ne
TPeerGroup, acquisition acquiescence point group meeting point service, newly-built privately owned some group JxtaPrivateG
Roup, issue newly-built privately owned some group notice, obtain newly-built privately owned some group meeting point service, set
Putting node A is newly-built privately owned some group meeting point, the meeting point event of circulation monitoring newly-built electricity group.
In the present embodiment, JXTASocket agent node and JXTASoap agent node are in privately owned node group
Meeting point A realizes P2P peer-to-peer communications, comprises the following steps that.
As it is shown in figure 5, the course of work of JXTASocket agent node is:
1) create a Socket Server, receive the request of (being positioned in Internet of Things) client；
2) configuration node, then starts JXTA platform, adds acquiescence point group NetPeerGroup, searches
JxtaPrivateGroup is organized a little in rope private；
3) if can not find privately owned some group, directly giving information, and quitting a program；Otherwise, look for
Arrive privately owned node group, then added privately owned node group and continue below step；
4) issue pipe service by the pipe service of privately owned node group to announce, set up input and efferent duct
Road so that other nodes can find this node and communicate；
5) the 1st) step create serve port monitor client request, after receiving request, according to
The pipe service of required parameter search JxtaSoap node, without the service pipe finding correspondence
Road, provides information, again the 5th) step continues to monitor at serve port；If it is right to find
The JxtaSoap node pipe service of the WEB server end answered, then continue below step；
6) by pipeline asking by JXTA forwarded to the JxtaSo of WEB server client
Ap node；
7) the return result of WEB server end JxtaSoap node is monitored at input channel；
8), after listening to the return result of JxtaSoap node, visitor is returned to by Socket communication mode
Family end, completes the most complete end-to-end service.
JXTASoap agent node, as the agency of WEB service end, is responsible for WEB service end data frame at JX
Communication in TA network.As shown in Figure 6, the course of work of JXTASoap agent node is:
1) configuration node, starts JXTA platform, adds acquiescence point group NetPeerGroup, (obtains
Acquiescence point group finds service), search for privately owned node group JxtaPrivateGroup；
2) if can not find privately owned some group, directly giving information, and quitting a program；If found
Privately owned node group JxtaPrivateGroup, then add ingress group and continue below step；
3) issue pipe service by the pipe service of privately owned node group JxtaPrivateGroup to announce
, set up input and output channel so that other nodes can find this node and communicate；
4) monitor input channel, receive the client-side service request that JXTASocket agent node is sent
；
5) the service request received being forwarded to by the way of SOAP communicates Web server, wait is returned
Return result；
6) the return result of Web server, the service pipeline of search JxtaSocket agent node are received
Service, without finding corresponding service pipeline, provides information, exits thread；As
Fruit have found the JxtaSocket node pipe service of correspondence, then continue below step；
7) create output channel, and by output channel, the return result of Web server is transmitted to J
XtaSocket node.
Claims (1)
1. P2P communication means based on JXTA platform under an environment of internet of things, it is characterised in that
Comprise the following steps:
The JXTASocket agent node running on client connects default node by JXTA network
Group, and join in described default node group；The JXTASocket agent node of described client is in institute
State and default node group is searched for privately owned node group, and add in described privately owned node group；Described client
JXTASocket agent node add after described privately owned node group, it is thus achieved that pipe service, and create the
One input channel and the first output channel, monitored by described first input channel and obtained client
Data, send the data listened to by the first output channel, and by described first input channel
Monitor the response data that JXTASoap agent node returns；Run on WEB server end
JXTASoap agent node connects default node group by JXTA network, and joins described acquiescence joint
In some group；The JXTASoap agent node of described WEB server end is searched in described default node group
Rope privately owned node group, and add in described privately owned node group；The JXTASoap of described WEB server end
Agent node adds after described privately owned node group, it is thus achieved that pipe service, and create the second input channel and
Second output channel, carries out data communication by described second input channel and described first output channel,
Data communication is carried out by the second output channel and described WEB server end；
JXTASocket agent node in described client and the JXTASoap in WEB server end
Agent node realizes P2P communication in described default node group；JXTASocket in described client
Agent node and the JXTASoap agent node in WEB server end are real in described privately owned node group
Existing P2P communication；
Described JXTASocket agent node and JXTASoap agent node are in privately owned node group meeting point
A realizes P2P peer-to-peer communications, specifically comprises the following steps that
The course of work of JXTASocket agent node is:
1) create a Socket Server, receive client request；
2) configuration node, then starts JXTA platform, adds default node group
NetPeerGroup, searches for privately owned node group JxtaPrivateGroup；
3) if can not find privately owned node group, directly giving information, and quitting a program；Instead
It, have found privately owned node group, then add privately owned node group and continue below step；
4) issue pipe service by the pipe service of privately owned node group to announce, set up input with defeated
Go out pipeline so that other nodes can find this node and communicate；
5) the 1st) step create serve port monitor client request, after receiving request, root
According to the pipe service of required parameter search JXTASoap agent node, without the clothes finding correspondence
Business pipeline, provides information, again the 5th) step continues to monitor at serve port；If it is right to find
The JXTASoap agent node pipe service of the WEB server end answered, then continue below step；
6) by pipeline asking by JXTA forwarded to WEB server client
JXTASoap agent node；
7) the return result of WEB server end JXTASoap agent node is monitored at input channel；
8) after listening to the return result of JXTASoap agent node, by Socket communication mode
Return to client, complete the most complete end-to-end service；
The course of work of JXTASoap agent node is:
1) configuration node, starts JXTA platform, adds default node group NetPeerGroup, obtains silent
Recognize a group and find service, search for privately owned node group JxtaPrivateGroup；
2) if can not find privately owned node group, directly giving information, and quitting a program；If looked for
Arrive privately owned node group JxtaPrivateGroup, then added ingress group and continue below step；
3) issue pipe service by the pipe service of privately owned node group JxtaPrivateGroup to announce, build
Vertical input and output channel so that other nodes can find this node and communicate；
4) monitoring input channel, the client service that reception JXTASocket agent node is sent please
Ask；
5) the service request received is forwarded to Web server by the way of SOAP communicates, waits
Return result；
6) the return result of Web server, the service pipeline of search JXTASocket agent node are received
Service, without finding corresponding service pipeline, provides information, exits thread；If looked for
Arrive the JXTASocket agent node pipe service of correspondence, then continue below step；
7) create output channel, and by output channel, the return result of Web server is transmitted to
JXTASocket agent node.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201310214976.4A CN103312799B (en) | 2013-05-31 | 2013-05-31 | P2P communication means based on JXTA platform under environment of internet of things |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201310214976.4A CN103312799B (en) | 2013-05-31 | 2013-05-31 | P2P communication means based on JXTA platform under environment of internet of things |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN103312799A CN103312799A (en) | 2013-09-18 |
| CN103312799B true CN103312799B (en) | 2016-08-17 |
Family
ID=49137577
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201310214976.4A Expired - Fee Related CN103312799B (en) | 2013-05-31 | 2013-05-31 | P2P communication means based on JXTA platform under environment of internet of things |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN103312799B (en) |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1767543A (en) * | 2004-10-08 | 2006-05-03 | 汤姆森许可贸易公司 | Method for establishing communication between peer-groups |
| GB2420257A (en) * | 2004-11-16 | 2006-05-17 | Vodafone Plc | Peer to peer (P2P) network wherein the quantity of super-peers is controlled in dependence upon their capacity to store service advertisements |
| CN102378407A (en) * | 2010-08-26 | 2012-03-14 | 中国人民解放军国防科学技术大学 | Object name resolution system and method in internet of things |
-
2013
- 2013-05-31 CN CN201310214976.4A patent/CN103312799B/en not_active Expired - Fee Related
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1767543A (en) * | 2004-10-08 | 2006-05-03 | 汤姆森许可贸易公司 | Method for establishing communication between peer-groups |
| GB2420257A (en) * | 2004-11-16 | 2006-05-17 | Vodafone Plc | Peer to peer (P2P) network wherein the quantity of super-peers is controlled in dependence upon their capacity to store service advertisements |
| CN102378407A (en) * | 2010-08-26 | 2012-03-14 | 中国人民解放军国防科学技术大学 | Object name resolution system and method in internet of things |
Non-Patent Citations (1)
| Title |
|---|
| 吕延庆.基于JXTA的P2P网络数据传输.《现代计算机》.2006, * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN103312799A (en) | 2013-09-18 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN106375214B (en) | A kind of Tiered routing determining method of path and device based on SDN | |
| CN104394224A (en) | Load balance system | |
| CN104811371B (en) | A kind of brand-new instantaneous communication system | |
| CN112769602B (en) | System and method for unified configuration management of white box switch and network operating system | |
| CN106790222B (en) | MODBUS/full-interconnection manufacturing network information service adapter and implementation method thereof | |
| CN103780467B (en) | communication connection method, communication device and communication system | |
| CN105376299A (en) | A network communication method, an apparatus and a network attached storage apparatus | |
| US20200280502A1 (en) | Network device snapshots | |
| CN105323310A (en) | Network communication method, device and network attached storage device | |
| CN103546572A (en) | Cloud storage device and multi-cloud storage networking system and method | |
| CN106161500A (en) | The communication module of a kind of remote wireless control electric equipment and control method | |
| JP6211975B2 (en) | Network extension system, control device, and network extension method | |
| CN112911001A (en) | Cloud VPN and enterprise network automatic networking scheme | |
| CN109120726A (en) | A kind of multi-router VPN automatic network-building method and system based on collection medium-long range control | |
| CN109088951A (en) | Memory card device | |
| CN104967572A (en) | Network access method, apparatus and equipment | |
| CN100490393C (en) | Method for accessing user network management platform | |
| CN106936935A (en) | A kind of long-range control method and device | |
| CN103312799B (en) | P2P communication means based on JXTA platform under environment of internet of things | |
| CN108683561A (en) | A kind of station state detection method and device | |
| CN110971519A (en) | Port interconnection management method and device | |
| CN110192382A (en) | A kind of network communication method, peer-to-peer and system | |
| CN116074160A (en) | Virtual networking public network forwarding method for GPU rendering computing node cluster | |
| CN103220203B (en) | A kind of method realizing LA Management Room many IPsec tunnel and set up | |
| CN103152202B (en) | Parameter deployment, communication node and communication network |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C14 | Grant of patent or utility model | ||
| GR01 | Patent grant | ||
| CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20160817 Termination date: 20170531 |
|
| CF01 | Termination of patent right due to non-payment of annual fee |