1

我的系统中安装了数据库SQL Server 2012和 activemq。我可以使用java程序向activemq发送消息并从activemq接收消息。我编写了两个名为 MessageProducer 和 MessageConsumer 的 java 程序，分别用于发送和接收。现在我想将消息从数据库发送到 activemq，有人可以帮我这样做吗？

注意：我可以在同一个数据库中发送和接收消息，我是通过以下链接进行的。但它在同一个数据库中甚至不在不同的 SQL Server 之间。我想我应该endpoints用于服务器-服务器通信，我试过但我不知道如何使用。

编辑我的问题感觉很舒服。

感谢您花时间看我的问题。

编辑：经过少量搜索后，我做了这样的事情来从数据库发送消息

--Create a Service Broker endpoint
USE master;
GO
IF EXISTS (SELECT * FROM sys.endpoints
          WHERE name = N'InstInitiatorEndpoint')
 DROP ENDPOINT InstInitiatorEndpoint;
GO
CREATE ENDPOINT InstInitiatorEndpoint
STATE = STARTED
AS TCP ( LISTENER_PORT = 61616 )
FOR SERVICE_BROKER (AUTHENTICATION = WINDOWS );
GO

--Create the Initiator database, master key, and user
USE master;
GO
IF EXISTS (SELECT * FROM sys.databases
       WHERE name = N'InstInitiatorDB')
 DROP DATABASE InstInitiatorDB;
GO
CREATE DATABASE InstInitiatorDB;
GO
USE InstInitiatorDB;
GO

CREATE MASTER KEY
   ENCRYPTION BY PASSWORD = N'<EnterStrongPassword2Here>';
GO
CREATE USER InitiatorUser WITHOUT LOGIN;
GO

--Create the Initiator certificate
CREATE CERTIFICATE InstInitiatorCertificate
 AUTHORIZATION InitiatorUser
 WITH SUBJECT = N'Initiator Certificate',
      EXPIRY_DATE = N'12/31/2013';

 BACKUP CERTIFICATE InstInitiatorCertificate
  TO FILE = 
  N'I:\MsSql\QueryNotification\InstTargetCertificate.cer';
GO


 --Create the message types

 CREATE MESSAGE TYPE [//BothDB/2InstSample/RequestMessage]
   VALIDATION = WELL_FORMED_XML;
 GO

--Create the contract
CREATE CONTRACT [//BothDB/2InstSample/SimpleContract]
  (     [//BothDB/2InstSample/RequestMessage]   SENT BY INITIATOR
  );
GO

--Create the Initiator queue and service

CREATE QUEUE InstInitiatorQueue;

CREATE SERVICE [//InstDB/2InstSample/InitiatorService]
   AUTHORIZATION InitiatorUser
   ON QUEUE InstInitiatorQueue;
GO


--Create routes

DECLARE @Cmd NVARCHAR(4000);

SET @Cmd = N'USE msdb
CREATE ROUTE InstInitiatorRoute
WITH SERVICE_NAME =
   N''//InstDB/2InstSample/InitiatorService'',
 ADDRESS = N''TCP://localhost:61616''';

EXEC (@Cmd);
GO

activemq tcp 端口是tcp//localhost:61616，我的 sql server 运行端口是1433. 在此之后我应该怎么做才能从 sql server 发送消息并在 activemq 的队列中查看消息？

4

0 回答 0