[go: up one dir, main page]

RU2008139292A - Основанная на политике архитектура агрегации сообщений - Google Patents

Основанная на политике архитектура агрегации сообщений Download PDF

Info

Publication number
RU2008139292A
RU2008139292A RU2008139292/09A RU2008139292A RU2008139292A RU 2008139292 A RU2008139292 A RU 2008139292A RU 2008139292/09 A RU2008139292/09 A RU 2008139292/09A RU 2008139292 A RU2008139292 A RU 2008139292A RU 2008139292 A RU2008139292 A RU 2008139292A
Authority
RU
Russia
Prior art keywords
packet
messages
computer
message
instance
Prior art date
Application number
RU2008139292/09A
Other languages
English (en)
Inventor
Картик ПАРАМИСИВАМ (US)
Картик ПАРАМИСИВАМ
Вэй-Лунь ЛО (US)
Вэй-Лунь ЛО
Руслан ЯКУШЕВ (US)
Руслан ЯКУШЕВ
Original Assignee
Майкрософт Корпорейшн (Us)
Майкрософт Корпорейшн
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Майкрософт Корпорейшн (Us), Майкрософт Корпорейшн filed Critical Майкрософт Корпорейшн (Us)
Publication of RU2008139292A publication Critical patent/RU2008139292A/ru

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/54—Interprogram communication
    • G06F9/546—Message passing systems or structures, e.g. queues
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q10/00—Administration; Management
    • G06Q10/06—Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q10/00—Administration; Management
    • G06Q10/10—Office automation; Time management
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F2209/00—Indexing scheme relating to G06F9/00
    • G06F2209/54—Indexing scheme relating to G06F9/54
    • G06F2209/547—Messaging middleware

Landscapes

  • Engineering & Computer Science (AREA)
  • Business, Economics & Management (AREA)
  • Theoretical Computer Science (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Human Resources & Organizations (AREA)
  • Strategic Management (AREA)
  • Physics & Mathematics (AREA)
  • Economics (AREA)
  • General Physics & Mathematics (AREA)
  • General Business, Economics & Management (AREA)
  • Tourism & Hospitality (AREA)
  • Quality & Reliability (AREA)
  • Operations Research (AREA)
  • Marketing (AREA)
  • Software Systems (AREA)
  • Educational Administration (AREA)
  • Development Economics (AREA)
  • Game Theory and Decision Science (AREA)
  • Data Mining & Analysis (AREA)
  • General Engineering & Computer Science (AREA)
  • Computer And Data Communications (AREA)
  • Debugging And Monitoring (AREA)
  • Information Transfer Between Computers (AREA)
  • Stored Programmes (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

1. Компьютеризированный способ агрегации сообщений, содержащий этапы, на которых: ! принимают множество сообщений (302) из, по меньшей мере, одного приложения (202); ! приводят в исполнение политику (306) конфигурирования пакетов на принятых сообщениях; ! агрегируют принятые сообщения в пакет (310) в зависимости от политики конфигурирования пакетов; ! собирают пакет в однопоточный вывод (316) сообщений. ! 2. Способ по п.1, в котором однопоточный вывод сообщений адресуется в конечную точку (408). ! 3. Способ по п.1, в котором приведение в исполнение дополнительно содержит этап, на котором хранят состояние (402) экземпляра, ассоциативно связанное с пакетом. ! 4. Способ по п.3, дополнительно содержащий этап, на котором сохраняют состояние (402) экземпляра в хранилище (108) данных. ! 5. Способ по п.4, в котором прием, приведение в исполнение и хранение ассоциативно связаны с первым компьютером, а хранилище (108) данных ассоциативно связано со вторым компьютером. ! 6. Способ по п.1, в котором прием дополнительно содержит этап, на котором сохраняют принятые сообщения (404) в хранилище (108) данных. ! 7. Способ по п.1, в котором политика конфигурирования пакетов содержит бизнес-логику, чтобы объединять в пакеты сообщения для приложения (102). ! 8. Способ по п.7, в котором бизнес-логика включает в себя, по меньшей мере, один из следующих параметров политики: порядок сортировки сообщений в пакете, число сообщений в пакете, совокупное число байтов в пакете, один или более типов сообщений в пакете и период времени накопления сообщений. ! 9. Способ по п.1, в котором агрегация дополнительно содержит этап, на котором сортируют сообщения как функцию от конфигурационной полити�

Claims (20)

1. Компьютеризированный способ агрегации сообщений, содержащий этапы, на которых:
принимают множество сообщений (302) из, по меньшей мере, одного приложения (202);
приводят в исполнение политику (306) конфигурирования пакетов на принятых сообщениях;
агрегируют принятые сообщения в пакет (310) в зависимости от политики конфигурирования пакетов;
собирают пакет в однопоточный вывод (316) сообщений.
2. Способ по п.1, в котором однопоточный вывод сообщений адресуется в конечную точку (408).
3. Способ по п.1, в котором приведение в исполнение дополнительно содержит этап, на котором хранят состояние (402) экземпляра, ассоциативно связанное с пакетом.
4. Способ по п.3, дополнительно содержащий этап, на котором сохраняют состояние (402) экземпляра в хранилище (108) данных.
5. Способ по п.4, в котором прием, приведение в исполнение и хранение ассоциативно связаны с первым компьютером, а хранилище (108) данных ассоциативно связано со вторым компьютером.
6. Способ по п.1, в котором прием дополнительно содержит этап, на котором сохраняют принятые сообщения (404) в хранилище (108) данных.
7. Способ по п.1, в котором политика конфигурирования пакетов содержит бизнес-логику, чтобы объединять в пакеты сообщения для приложения (102).
8. Способ по п.7, в котором бизнес-логика включает в себя, по меньшей мере, один из следующих параметров политики: порядок сортировки сообщений в пакете, число сообщений в пакете, совокупное число байтов в пакете, один или более типов сообщений в пакете и период времени накопления сообщений.
9. Способ по п.1, в котором агрегация дополнительно содержит этап, на котором сортируют сообщения как функцию от конфигурационной политики.
10. Способ по п.1, в котором сообщения соответствуют стандарту EDI (электронного обмена данными).
11. Способ по п.1, в котором один или более машиночитаемых носителей имеют машиноисполняемые команды для выполнения способа по п.1.
12. Компьютеризированный способ агрегации сообщений, содержащий этапы, на которых:
принимают множество сообщений из, по меньшей мере, одного приложения (302), причем упомянутые сообщения включают в себя идентификатор пакета и индикатор конца пакета;
агрегируют принятые сообщения (308) в пакет как функцию от идентификатора пакета;
завершают агрегацию (310) как функцию от индикатора конца пакета;
собирают пакет (316) в однопоточный вывод сообщений.
13. Способ по п.12, дополнительно содержащий этап, на котором хэшируют идентификатор пакета, чтобы определить экземпляр формирователя пакетов для агрегации сообщений.
14. Способ по п.12, в котором индикатор конца пакета сигнализирует, когда пакет завершен.
15. Способ по п.12, в котором однопоточный вывод сообщений адресуется в конечную точку.
16. Способ по п.12, дополнительно содержащий этап, на котором хранят состояние (402) экземпляра, ассоциативно связанное с пакетом.
17. Способ по п.16, дополнительно содержащий этап, на котором сохраняют состояние (402) экземпляра в хранилище (108) данных.
18. Способ по п.12, в котором один или более машиночитаемых носителей имеют машиноисполняемые команды для осуществления способа по п.12.
19. Система агрегации сообщений для приложения (102), причем упомянутые сообщения адресуются на порт отправки, при этом упомянутая система содержит один или более машиноисполняемых компонентов, содержащих:
компонент (104) механизма обмена сообщениями для приема сообщения из приложения;
политику (106) конфигурирования пакетов, причем упомянутая политика конфигурирования пакетов содержит бизнес-логику, чтобы объединять в пакеты сообщения для приложения;
компонент (106) формирователя пакетов для агрегации сообщений в пакет в зависимости от политики (106) конфигурирования пакетов, причем упомянутый компонент (106) формирователя пакетов ассоциативно связан с портом отправки, причем упомянутый компонент (106) формирователя пакетов принимает сообщения, адресованные для порта отправки, из механизма (104) сообщений; и
при этом компонент (104) механизма обмена сообщениями создает новый экземпляр формирователя (106) пакетов, ассоциативно связанный с портом отправки, если компонент (106) формирователя пакетов, ассоциативно связанный с портом отправки, не существует.
20. Система по п.19, в которой компонент (104) механизма обмена сообщениями ассоциативно связан с первым компьютером и хранит состояние (402) экземпляра пакета, сохраненного в хранилище данных, ассоциативно связанном со вторым компьютером, при этом упомянутое состояние (402) экземпляра включает в себя идентификатор сообщения и идентификатор порта отправки; и
при этом компонент (102) механизма обмена сообщениями ассоциативно связан с первым компьютером и сохраняет сообщение в упомянутом хранилище (108) данных, ассоциативно связанном с упомянутым вторым компьютером.
RU2008139292/09A 2006-04-03 2007-03-08 Основанная на политике архитектура агрегации сообщений RU2008139292A (ru)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
US11/396,665 US7890955B2 (en) 2006-04-03 2006-04-03 Policy based message aggregation framework
US11/396,665 2006-04-03

Publications (1)

Publication Number Publication Date
RU2008139292A true RU2008139292A (ru) 2010-04-10

Family

ID=38561084

Family Applications (1)

Application Number Title Priority Date Filing Date
RU2008139292/09A RU2008139292A (ru) 2006-04-03 2007-03-08 Основанная на политике архитектура агрегации сообщений

Country Status (10)

Country Link
US (1) US7890955B2 (ru)
EP (1) EP2013827A4 (ru)
JP (1) JP5026506B2 (ru)
KR (1) KR20080106568A (ru)
CN (1) CN101416209A (ru)
BR (1) BRPI0710091A2 (ru)
CA (1) CA2647138A1 (ru)
MX (1) MX2008012378A (ru)
RU (1) RU2008139292A (ru)
WO (1) WO2007120410A1 (ru)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
RU2544755C2 (ru) * 2010-04-26 2015-03-20 Тенсент Текнолоджи (Шэньчжэнь) Компани Лимитед Способ, система и сервер для управления подачей информации от друзей в сети

Families Citing this family (22)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20080126385A1 (en) * 2006-09-19 2008-05-29 Microsoft Corporation Intelligent batching of electronic data interchange messages
US7844658B2 (en) 2007-01-22 2010-11-30 Comcast Cable Holdings, Llc System and method for providing an application to a device
US20100125740A1 (en) * 2008-11-19 2010-05-20 Accenture Global Services Gmbh System for securing multithreaded server applications
US8918521B2 (en) * 2009-06-03 2014-12-23 Microsoft Corporation Batching of messages for mobile endpoint
US9367371B2 (en) * 2010-02-05 2016-06-14 Paypal, Inc. Widget framework, real-time service orchestration, and real-time resource aggregation
EP2444899A1 (en) * 2010-10-20 2012-04-25 HTC Corporation Method of handling step execution result in software and application control management object
JP2012194918A (ja) * 2011-03-17 2012-10-11 Toshiba Corp 通信媒体、ｉｃカード、及び通信方法
US8984078B2 (en) * 2013-01-11 2015-03-17 Google Inc. Systems and methods for device-to-cloud message delivery
US10140318B1 (en) * 2013-07-01 2018-11-27 Allscripts Software, Llc Microbatch loading
KR101485819B1 (ko) * 2014-09-05 2015-01-23 (주) 메가투스 메시지 변환 장치
KR101678195B1 (ko) * 2014-12-29 2016-11-22 (주) 메가투스 메시지 변환 방법 및 변환 장치, 이를 위한 컴퓨터 프로그램, 그 기록매체
US10726389B2 (en) * 2015-04-21 2020-07-28 Walmart Apollo, Llc Inventory information distribution systems, devices and methods
US10594828B2 (en) 2016-04-19 2020-03-17 International Business Machines Corporation Delivery of incremental sensor data over optimized channel
US10628211B2 (en) * 2017-06-15 2020-04-21 Mastercard International Incorporated Systems and methods for asynchronously consolidating and transmitting data
CN107590696A (zh) * 2017-09-15 2018-01-16 北京凤凰理理它信息技术有限公司 消息推送方法、装置、存储介质及电子设备
CN111488222B (zh) * 2019-01-25 2023-04-07 杭州海康威视数字技术股份有限公司 一种流聚合方法、装置及电子设备
US11711374B2 (en) 2019-05-31 2023-07-25 Varmour Networks, Inc. Systems and methods for understanding identity and organizational access to applications within an enterprise environment
US11863580B2 (en) 2019-05-31 2024-01-02 Varmour Networks, Inc. Modeling application dependencies to identify operational risk
US10891176B1 (en) * 2019-08-09 2021-01-12 Ciena Corporation Optimizing messaging flows in a microservice architecture
US11842060B2 (en) * 2020-09-04 2023-12-12 Cohesity, Inc. Efficiently storing data in a cloud storage
US11818152B2 (en) * 2020-12-23 2023-11-14 Varmour Networks, Inc. Modeling topic-based message-oriented middleware within a security system
US11876817B2 (en) 2020-12-23 2024-01-16 Varmour Networks, Inc. Modeling queue-based message-oriented middleware relationships in a security system

Family Cites Families (24)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2667818B2 (ja) * 1986-10-09 1997-10-27 株式会社日立製作所 トランザクション処理方法
US5361353A (en) * 1991-10-02 1994-11-01 International Business Machines Corporation System for parsing message units from an unstructured message stream of interleaved message units to form structured messages
US6963920B1 (en) * 1993-11-19 2005-11-08 Rose Blush Software Llc Intellectual asset protocol for defining data exchange rules and formats for universal intellectual asset documents, and systems, methods, and computer program products related to same
US5875329A (en) * 1995-12-22 1999-02-23 International Business Machines Corp. Intelligent batching of distributed messages
US20010031454A1 (en) * 1997-05-30 2001-10-18 Alex Mintz Multi-functional communication and aggregation platform
US6820266B1 (en) * 1998-02-27 2004-11-16 Oracle International Corporation Application code conversion architecture
US6148298A (en) * 1998-12-23 2000-11-14 Channelpoint, Inc. System and method for aggregating distributed data
US20010013069A1 (en) * 1999-01-11 2001-08-09 Infospace, Inc. Data messaging aggregation
US6697960B1 (en) * 1999-04-29 2004-02-24 Citibank, N.A. Method and system for recovering data to maintain business continuity
US20020049790A1 (en) * 2000-08-08 2002-04-25 Ricker Jeffrey M Data interchange format transformation method and data dictionary used therefor
US6886046B2 (en) * 2001-06-26 2005-04-26 Citrix Systems, Inc. Methods and apparatus for extendible information aggregation and presentation
US7155483B1 (en) * 2001-08-07 2006-12-26 Good Technology, Inc. Apparatus and method for conserving bandwidth by batch processing data transactions
JP2004005204A (ja) * 2002-05-31 2004-01-08 Ufit Co Ltd 情報処理システム
JP2004072485A (ja) * 2002-08-07 2004-03-04 Nippon Telegr & Teleph Corp <Ntt> プレゼンス情報通知装置、プレゼンス情報通知プログラム、プログラム記録媒体、及びプレゼンス情報通知方法
US7346669B2 (en) * 2002-12-19 2008-03-18 Intel Corporation Method, apparatus and system for processing message bundles on a network
US7336607B2 (en) * 2002-12-27 2008-02-26 Lucent Technologies Inc. Methods and apparatus for flow control based packet aggregation in a communication network
US7111047B2 (en) * 2003-08-08 2006-09-19 Teamon Systems, Inc. Communications system providing message aggregation features and related methods
US7765300B2 (en) * 2003-10-06 2010-07-27 Ericsson Ab Protocol for messaging between a centralized broadband remote aggregation server and other devices
US20050255833A1 (en) * 2004-05-13 2005-11-17 Mobile (R&D) Ltd. Message aggregation system and method for a mobile communication device
US7870200B2 (en) 2004-05-29 2011-01-11 Ironport Systems, Inc. Monitoring the flow of messages received at a server
US20050278731A1 (en) * 2004-06-09 2005-12-15 Navic Systems, Inc. System and method of anonymous settop event collection and processing in a multimedia network
JP2006065753A (ja) * 2004-08-30 2006-03-09 Toshiba Corp 会話管理装置、方法及びプログラム
US8238350B2 (en) * 2004-10-29 2012-08-07 Emc Corporation Message batching with checkpoints systems and methods
US7706895B2 (en) * 2005-02-25 2010-04-27 Rockwell Automation Technologies, Inc. Reliable messaging instruction

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
RU2544755C2 (ru) * 2010-04-26 2015-03-20 Тенсент Текнолоджи (Шэньчжэнь) Компани Лимитед Способ, система и сервер для управления подачей информации от друзей в сети

Also Published As

Publication number Publication date
KR20080106568A (ko) 2008-12-08
US7890955B2 (en) 2011-02-15
EP2013827A4 (en) 2011-06-29
BRPI0710091A2 (pt) 2011-08-02
CN101416209A (zh) 2009-04-22
MX2008012378A (es) 2008-10-09
CA2647138A1 (en) 2007-10-25
US20070234369A1 (en) 2007-10-04
JP5026506B2 (ja) 2012-09-12
WO2007120410A1 (en) 2007-10-25
JP2009532803A (ja) 2009-09-10
EP2013827A1 (en) 2009-01-14

Similar Documents

Publication Publication Date Title
RU2008139292A (ru) Основанная на политике архитектура агрегации сообщений
CN111131084B (zh) 一种QoS感知的OpenFlow流表查找方法
CN102142009B (zh) 一种正则表达式匹配的方法及装置
CN101252532B (zh) 以太网链路聚合端口配置的方法和设备
CN105474168B (zh) 网络装置执行的数据处理方法和相关设备
CN101630992B (zh) 共享内存管理方法
CN101483605B (zh) 数据报文的存储、查找方法和装置
Langlet et al. Direct telemetry access
CN110808854B (zh) 报文调度方法、装置及交换机
CN101789908A (zh) 分片报文接收处理方法及装置
CN103684911A (zh) 一种网站的在线用户统计方法和装置
CN104009924B (zh) 一种基于tcam和fpga的报文处理方法及装置
CN103986585A (zh) 报文预处理方法及其装置
CN101741737B (zh) 路由表的维护方法与装置
US7984235B2 (en) Reducing content addressable memory (CAM) power consumption counters
CN106254270A (zh) 一种队列管理方法及装置
CN101540722A (zh) 以太网链路聚合端口配置的方法和设备
CN102143151B (zh) 一种基于深度包检测的协议跨包检测方法和装置
CN100589477C (zh) 一种基于绑定链路实现数据发送的方法
CN103812774A (zh) 基于tcam的策略配置方法、报文处理方法及相应装置
CN111988158B (zh) 芯片级实现oam报文发送方法、装置、系统及存储介质
CN104735060B (zh) 路由器及其数据平面信息的验证方法和验证装置
RU2013127143A (ru) Быстрое установление соответствия при адресации по содержанию (контенту)
CN107800630A (zh) 报文处理方法及装置
CN101645852B (zh) 一种网络包分类的设备和方法

Legal Events

Date Code Title Description
FA93 Acknowledgement of application withdrawn (no request for examination)

Effective date: 20100309