common java socket_Java SocketConnection.connect方法代碼示例

蔚落 2022-10-23 04:56 88阅读 0赞

本文整理匯總了Java中org.simpleframework.transport.connect.SocketConnection.connect方法的典型用法代碼示例。如果您正苦於以下問題：Java SocketConnection.connect方法的具體用法？Java SocketConnection.connect怎麽用？Java SocketConnection.connect使用的例子？那麽恭喜您, 這裏精選的方法代碼示例或許可以為您提供幫助。您也可以進一步了解該方法所在類org.simpleframework.transport.connect.SocketConnection的用法示例。

在下文中一共展示了SocketConnection.connect方法的10個代碼示例，這些例子默認根據受歡迎程度排序。您可以為喜歡或者感覺有用的代碼點讚，您的評價將有助於我們的係統推薦出更棒的Java代碼示例。

示例1: createServer

點讚 3

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

public static Connection createServer(boolean certificateRequired, int listenPort) throws Exception \{

System.setProperty("sun.security.ssl.allowUnsafeRenegotiation", "true");

System.setProperty("sun.security.ssl.allowLegacyHelloMessages", "true");

File file = new File("C:\\\\work\\\\development\\\\async\_http\\\\yieldbroker-proxy-trading\\\\etc\\\\uat.yieldbroker.com.pfx");

KeyStoreReader reader = new KeyStoreReader(KeyStoreType.PKCS12, file, "p", "p");

SecureSocketContext context = new SecureSocketContext(reader, SecureProtocol.TLS);

SSLContext sslContext = context.getContext();

Agent agent = new MockAgent();

TransportProcessor processor = new TransportProcessor();

ProcessorServer server = new ProcessorServer(processor);

ConfigurableCertificateServer certServer = new ConfigurableCertificateServer(server);

SocketConnection con = new SocketConnection(certServer, agent);

SocketAddress serverAddress = new InetSocketAddress(listenPort);

certServer.setCertRequired(certificateRequired);

con.connect(serverAddress, sslContext);

return con;

開發者ID:blobrobotics，項目名稱:bstation，代碼行數:20，

示例2: startServer

點讚 3

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

/\*\*

\* Will start the Server Mock as well as the RabbitMQ Listener

\* @throws IOException

\* @throws IguanaException

\* @throws TimeoutException

\*/

@BeforeClass

public static void startServer() throws IOException, IguanaException, TimeoutException \{

// start ServerMock

mock = new StresstestServerMock();

fastServer = new ContainerServer(mock);

fastConnection = new SocketConnection(fastServer);

address1 = new InetSocketAddress(8024);

fastConnection.connect(address1);

// start RabbitMQ listener

// queue declare

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

connection = factory.newConnection();

channel = connection.createChannel();

channel.queueDeclare(COMMON.CORE2RP\_QUEUE\_NAME, false, false, false, null);

開發者ID:dice-group，項目名稱:IGUANA，代碼行數:25，

示例3: metaTest

點讚 3

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

/\*\*

\* @throws IOException

\*/

@Test

public void metaTest() throws IOException\{

fastServerContainer = new ServerMock();

fastServer = new ContainerServer(fastServerContainer);

fastConnection = new SocketConnection(fastServer);

SocketAddress address1 = new InetSocketAddress(FAST\_SERVER\_PORT);

fastConnection.connect(address1);

String host = "http://localhost:8023";

TriplestoreStorage store = new TriplestoreStorage(host, host);

Properties p = new Properties();

p.put(COMMON.EXPERIMENT\_TASK\_ID\_KEY, "1/1/1");

p.setProperty(COMMON.EXPERIMENT\_ID\_KEY, "1/1");

p.setProperty(COMMON.CONNECTION\_ID\_KEY, "virtuoso");

p.setProperty(COMMON.SUITE\_ID\_KEY, "1");

p.setProperty(COMMON.DATASET\_ID\_KEY, "dbpedia");

p.put(COMMON.RECEIVE\_DATA\_START\_KEY, "true");

p.put(COMMON.EXTRA\_META\_KEY, new Properties());

p.put(COMMON.NO\_OF\_QUERIES, 2);

store.addMetaData(p);

assertEquals(metaExp.trim(), fastServerContainer.getActualContent().trim());

開發者ID:dice-group，項目名稱:IGUANA，代碼行數:27，

示例4: dataTest

點讚 3

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

/\*\*

\* @throws IOException

\*/

@Test

public void dataTest() throws IOException\{

fastServerContainer = new ServerMock();

fastServer = new ContainerServer(fastServerContainer);

fastConnection = new SocketConnection(fastServer);

SocketAddress address1 = new InetSocketAddress(FAST\_SERVER\_PORT);

fastConnection.connect(address1);

String host = "http://localhost:8023";

TriplestoreStorage store = new TriplestoreStorage(host, host);

Properties p = new Properties();

p.setProperty(COMMON.EXPERIMENT\_TASK\_ID\_KEY, "1/1/1");

p.put(COMMON.METRICS\_PROPERTIES\_KEY, "testMetric");

p.put(COMMON.EXTRA\_META\_KEY, new Properties());

Triple\[\] t = new Triple\[1\];

t\[0\] = new Triple("a", "b", "c");

store.addData(p, t);

store.commit();

assertEquals(dataExp.trim(),fastServerContainer.getActualContent().trim());

開發者ID:dice-group，項目名稱:IGUANA，代碼行數:25，

示例5: startServer

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

@Before

public void startServer() throws IOException \{

server = new ContainerServer(container);

connection = new SocketConnection(server);

SocketAddress address = new InetSocketAddress(SERVER\_PORT);

connection.connect(address);

開發者ID:dice-group，項目名稱:Squirrel，代碼行數:8，

示例6: startServer

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

@Before

public void startServer() throws IOException \{

fastServerContainer = new WaitingDocumentReturningServerMock(DOCUMENTS, 0);

fastServer = new ContainerServer(fastServerContainer);

fastConnection = new SocketConnection(fastServer);

SocketAddress address1 = new InetSocketAddress(FAST\_SERVER\_PORT);

fastConnection.connect(address1);

slowServer = new ContainerServer(new WaitingDocumentReturningServerMock(DOCUMENTS, SLOW\_SERVER\_WAITING\_TIME));

slowConnection = new SocketConnection(slowServer);

SocketAddress address2 = new InetSocketAddress(SLOW\_SERVER\_PORT);

slowConnection.connect(address2);

開發者ID:dice-group，項目名稱:gerbil，代碼行數:13，

示例7: HttpMockServer

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

public HttpMockServer(@Nonnull JSONObject jsonObject, @Nonnull ConfigReader configReader, @Nonnull NetworkType simulatedNetworkType)

throws IOException, JSONException \{

ConfigResult config = new ConfigParser(configReader).parseConfig(jsonObject);

MockNetworkLag networkLag = new MockNetworkLag(simulatedNetworkType);

this.responseHandler = new ResponseHandler(config.responses, networkLag, configReader);

Server server = new ContainerServer(this);

conn = new SocketConnection(server);

final SocketAddress sa = new InetSocketAddress(config.port);

conn.connect(sa);

開發者ID:byoutline，項目名稱:MockServer，代碼行數:11，

示例8: setUp

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

@Before

public void setUp() throws Exception \{

Server server = new ContainerServer(testContainer);

connection = new SocketConnection(server);

ServerSocket socketServer = new ServerSocket(0);

port = socketServer.getLocalPort();

socketServer.close();

connection.connect(new InetSocketAddress(port));

開發者ID:Kixeye，項目名稱:relax，代碼行數:12，

示例9: start

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

public void start() throws IOException \{

server = new FixdServer(new ContainerServer(container));

connection = new SocketConnection(server, new LoggingAgent());

SocketAddress address = new InetSocketAddress(port);

actualConnectionAddress = (InetSocketAddress)connection.connect(address);

開發者ID:lantunes，項目名稱:fixd，代碼行數:9，

示例10: run

點讚 2

import org.simpleframework.transport.connect.SocketConnection; //導入方法依賴的package包/類

public void run(final Application app, SSLContext context) throws IOException \{

connection = new SocketConnection(new ContainerSocketProcessor(new ApplicationContainer(app), numberOfThreads));

connection.connect(new InetSocketAddress(host, port), context);

開發者ID:testinfected，項目名稱:molecule，代碼行數:5，

注：本文中的org.simpleframework.transport.connect.SocketConnection.connect方法示例整理自Github/MSDocs等源碼及文檔管理平台，相關代碼片段篩選自各路編程大神貢獻的開源項目，源碼版權歸原作者所有，傳播和使用請參考對應項目的License；未經允許，請勿轉載。