Skip to content

Latest commit

 

History

History
222 lines (202 loc) · 5.9 KB

springmore-rpc.md

File metadata and controls

222 lines (202 loc) · 5.9 KB
Raw

springmore-rpc组件

  • 封装mina客户端
  • 实现mina的短连接通信，长连接同步通信，长连接异步通信
  • 关于mina更多的文章，请参考： mina参考文档
短连接传输字节

spring配置文件：

<!-- 短连接工厂 -->
<bean id="shortConnectFactory" class="org.springmore.rpc.mina.client.sc.ShortConnectFactory">
	<property name="host">
		<value>localhost</value>
	</property>
	<property name="port">
		<value>18886</value>
	</property>
	<property name="connectTimeoutMillis">
		<value>30000</value>
	</property>
	<property name="readBufferSize">
		<value>2048*2048</value>
	</property>
	<!-- protocolCodecFactory不配置则是字节传输 -->
</bean>

<!-- minaTemplate -->
<bean id="minaTemplate" class="org.springmore.rpc.mina.client.MinaTemplate">
	<property name="connectFactory" ref="shortConnectFactory"></property>
</bean>

java代码调用示例

@Autowired
MinaTemplate minaTemplate;
@Test
public void 发送字节() throws InterruptedException {
	
	byte[] s = minaTemplate.sengObject("fff".getBytes());
	System.out.println(new String(s));
	System.out.println(s);

}
短连接传输字符串

spring配置文件：

<!-- 传输字符串编码工厂 -->
<bean id="textLineCodecFactory" class="org.springmore.rpc.mina.codec.NewTextLineCodecFactory">
	<constructor-arg index="0" value="UTF-8"></constructor-arg>
</bean>
<!-- 短连接工厂 -->
<bean id="shortConnectFactory" class="org.springmore.rpc.mina.client.sc.ShortConnectFactory">
	<property name="host">
		<value>localhost</value>
	</property>
	<property name="port">
		<value>18886</value>
	</property>
	<property name="connectTimeoutMillis">
		<value>30000</value>
	</property>
	<property name="readBufferSize">
		<value>2048*2048</value>
	</property>
	<!-- protocolCodecFactory不配置则是字节传输 -->
	<property name="protocolCodecFactory" ref="textLineCodecFactory"/>
</bean>

<!-- minaTemplate -->
<bean id="minaTemplate" class="org.springmore.rpc.mina.client.MinaTemplate">
	<property name="connectFactory" ref="shortConnectFactory"></property>
</bean>

java代码示例：

@Autowired
MinaTemplate minaTemplate;

@Test
public void 发送字符串() throws InterruptedException {
	
	String s = minaTemplate.sengObject("xxx");
	System.out.println(s);

}
短连接传输自定义对象

spring配置文件：

<bean id="objectSerializationCodecFactory" class="org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory">
		
</bean>
<!-- 短连接工厂 -->
<bean id="shortConnectFactory" class="org.springmore.rpc.mina.client.sc.ShortConnectFactory">
	<property name="host">
		<value>localhost</value>
	</property>
	<property name="port">
		<value>18886</value>
	</property>
	<property name="connectTimeoutMillis">
		<value>30000</value>
	</property>
	<property name="readBufferSize">
		<value>2048*2048</value>
	</property>
	<!-- protocolCodecFactory不配置则是字节传输 -->
	<property name="protocolCodecFactory" ref="objectSerializationCodecFactory"/>
</bean>

<!-- minaTemplate -->
<bean id="minaTemplate" class="org.springmore.rpc.mina.client.MinaTemplate">
	<property name="connectFactory" ref="shortConnectFactory"></property>
</bean>

java代码示例：

@Autowired
MinaTemplate minaTemplate;
@Test
public void 发送对象() throws InterruptedException {
	User user = new User();
	user.setUserId(10);
	User user2 = minaTemplate.sengObject(user);
	System.out.println(user2.getUserId());
}
长连接同步通信

只有连接工厂配置不一样 spring配置文件：

<bean id="objectSerializationCodecFactory" class="org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory">
		
</bean>
<!-- 长连接接工厂 -->
<bean id="longConnectFactory" class="org.springmore.rpc.mina.client.lc.syn.LongConnectFactory">
	<property name="poolSize">
		<value>10</value>
	</property>
	<property name="host">
		<value>localhost</value>
	</property>
	<property name="port">
		<value>18886</value>
	</property>
	<property name="connectTimeoutMillis">
		<value>30000</value>
	</property>
	<property name="readBufferSize">
		<value>2048*2048</value>
	</property>
	<property name="protocolCodecFactory" ref="objectSerializationCodecFactory"/>
</bean>

<!-- minaTemplate -->
<bean id="minaTemplate" class="org.springmore.rpc.mina.client.MinaTemplate">
	<property name="connectFactory" ref="longConnectFactory"></property>
</bean>

java代码示例：

@Autowired
MinaTemplate minaTemplate;
@Test
public void 发送对象() throws InterruptedException {
	User user = new User();
	user.setUserId(10);
	User user2 = minaTemplate.sengObject(user);
	System.out.println(user2.getUserId());
}
长连接异步通信

只有连接工厂配置不一样 spring配置文件：

<bean id="objectSerializationCodecFactory" class="org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory">
		
</bean>
<!-- 连接工厂 -->
<bean id="aysnlongConnectFactory" class="org.springmore.rpc.mina.client.lc.asyn.LongAsynConnectFactory">
	<property name="poolSize">
		<value>10</value>
	</property>
	<property name="host">
		<value>localhost</value>
	</property>
	<property name="port">
		<value>18886</value>
	</property>
	<property name="connectTimeoutMillis">
		<value>30000</value>
	</property>
	<property name="readBufferSize">
		<value>2048*2048</value>
	</property>
	<property name="protocolCodecFactory" ref="objectSerializationCodecFactory"/>
</bean>

<!-- minaTemplate -->
<bean id="minaTemplate" class="org.springmore.rpc.mina.client.MinaTemplate">
	<property name="connectFactory" ref="aysnlongConnectFactory"></property>
</bean>

java代码示例：

@Autowired
MinaTemplate minaTemplate;
@Test
public void 发送对象() throws InterruptedException {
	User user = new User();
	user.setUserId(10);
	User user2 = minaTemplate.sengObject(user);
	System.out.println(user2.getUserId());
}