引用其它Bean
一、构造器注入方式Q?/strong>
Q?Q通过?<constructor-arg>”标{ref属性来引用其他Bean
Q?Q通过?<constructor-arg>”标{?lt;ref>标签来引用其他BeanQ用bean属性来指定引用的Bean
二、setter注入方式Q?/strong>
Q?Q通过?<property>”标{ref属性来引用其他Bean
Q?Q通过?<property>”标{?lt;ref>标签来引用其他BeanQ用bean属性来指定引用的Bean
public class HelloDiBean implements HelloApi{
private HelloApi helloApi;
private HelloApi helloApi2;
public HelloDiBean(HelloApi helloApi){
this.helloApi = helloApi;
}
public void sayHello() {
helloApi.sayHello();
helloApi2.sayHello();
}
public HelloApi getHelloApi2() {
return helloApi2;
}
public void setHelloApi2(HelloApi helloApi2) {
this.helloApi2 = helloApi2;
}
}
配置注入引用其他的bean
<!-- 引用其他的beanq行注入 --> <bean id="helloBean" class="com.dilist.HelloDiBean"> <constructor-arg index="0" ref="mapBean" /> <property name="helloApi2"> <ref bean="properBean" /> </property> </bean>
其他引用bean 的高U用法：
/**
* Springq提供了另外两种更高U的配置方式Q?lt;ref local=”?>?lt;ref parent=”?>Q?
* Q?Q?lt;ref local=”?>配置方式Q用于引用通过<bean id=”beanName?gt;方式中通过id属性指定的BeanQ?
* 它能利用XML解析器的验证功能在读取配|文件时来验证引用的Bean是否存在?
* 因此如果在当前配|文件中有相互引用的Bean可以采用<ref local>方式从而如果配|错误能在开发调试时发现错误?
* Q?Q?lt;ref parent=”?>配置方式Q用于引用父容器中的BeanQ不会引用当前容器中的BeanQ?
* 当然父容器中的Bean和当前容器的Bean是可以重名的Q获取顺序是直接到父容器找?
*/
public class HelloHigh implements HelloApi{
private HelloApi helloApi;
private HelloApi helloApi2;
public HelloHigh(HelloApi helloApi){
this.helloApi = helloApi;
}
public void sayHello() {
helloApi.sayHello();
System.out.println("");
helloApi2.sayHello();
}
public HelloApi getHelloApi2() {
return helloApi2;
}
public void setHelloApi2(HelloApi helloApi2) {
this.helloApi2 = helloApi2;
}
}
helloworld.xmlQ?/span>
<!-- 注入propertiescd --> <bean id="properBean" class="com.dilist.HelloDiProperties"> <property name="properties"> <props value-type="int" merge="default"><!-- 虽然指定value-type,但是不v作用 --> <prop key="1">1sss</prop> <!-- Properties 建和值都是Stringcd --> <prop key="2">2</prop> </props> </property> <property name="properties2"> <value> <!-- 分隔W可以是 “换行”、“；”、“，?不徏议该方式Q优先选择W一U方?--> 1=11 2=22;<!-- q样的分隔符好像没用 --> 3=33, 4=44 </value> </property> </bean> <!-- Springq提供了另外两种更高U的配置方式Q?lt;ref local=”?>?lt;ref parent=”?> --> <bean id="helloHigh" class="com.dilist.HelloHigh"> <constructor-arg index="0"><ref local="properBean" /></constructor-arg> <property name="helloApi2"><ref parent="properBean" /></property> </bean>
helloworldParent.xmlQ?/span>
<!-- 注入propertiescd --> <bean id="properBean" class="com.dilist.HelloDiProperties"> <property name="properties"> <props value-type="int" merge="default"><!-- 虽然指定value-type,但是不v作用 --> <prop key="1">2dss</prop> <!-- Properties 建和值都是Stringcd --> <prop key="2">3aas</prop> </props> </property> <property name="properties2"> <value> <!-- 分隔W可以是 “换行”、“；”、“，?不徏议该方式Q优先选择W一U方?--> 1=111 2=222;<!-- q样的分隔符好像没用 --> 3=333, 4=444 </value> </property> </bean>
调用?利用加蝲父容器的方式Q注入父容器中的BeanQ?/p>
@Test
public void testDiBeanHigh() {
// 以classes为根目录v
// d配置文g实例化一个Ioc容器
// 初始化父容器
ApplicationContext parentContext = new ClassPathXmlApplicationContext(
"helloworldParent.xml");
// 初始化当前容?
ApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "helloworld.xml" }, parentContext);
// 构?+ setter注入 引用其他的bean注入
HelloApi helloApi = context.getBean("helloHigh", HelloApi.class);
helloApi.sayHello();
}
已有 0 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>
import org.objectweb.asm.ClassWriter;
import org.objectweb.asm.MethodVisitor;
import org.objectweb.asm.Opcodes;
public class HelloWorld extends ClassLoader implements Opcodes{
public static void main(String[] args) {
ClassWriter cw = new ClassWriter(0);
cw.visit(V1_1, ACC_PUBLIC, "Example", null, "java/lang/Object", null);
MethodVisitor mw = cw.visitMethod(ACC_PUBLIC, "<init>", "()V", null, null);
mw.visitVarInsn(ALOAD, 0);
mw.visitMethodInsn(INVOKESPECIAL, "java/lang/Object", "<init>", "()V");
mw.visitInsn(RETURN);
mw.visitMaxs(1, 1);
mw.visitEnd();
mw = cw.visitMethod(ACC_PUBLIC+ACC_STATIC, "main", "([Ljava/lang/String;)V", null, null);
mw.visitFieldInsn(GETSTATIC, "java/lang/System", "out", "Ljava/io/PrintStream;");
mw.visitLdcInsn("Hello World!");
mw.visitMethodInsn(INVOKEVIRTUAL, "java/io/PrintStream", "println", "(Ljava/lang/String;)V");
mw.visitInsn(RETURN);
mw.visitMaxs(2, 2);
mw.visitEnd();
byte[] code = cw.toByteArray();
FileOutputStream fos;
try {
fos = new FileOutputStream("Example.class");
fos.write(code);
fos.close();
HelloWorld loader = new HelloWorld();
Class exampleClass = loader
.defineClass("Example", code, 0, code.length);
exampleClass.getMethods()[0].invoke(null, new Object[] { null });
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SecurityException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
cglib 动态生成class q进行拦?/pre>
public class MyClass { public void print() { System.out.println("I'm in MyClass.print!"); } } import net.sf.cglib.proxy.Callback; import net.sf.cglib.proxy.Enhancer; import net.sf.cglib.proxy.MethodInterceptor; import net.sf.cglib.proxy.MethodProxy; public class Main { public static void main(String[] args) { Enhancer enhancer = new Enhancer(); enhancer.setSuperclass(MyClass.class); enhancer.setCallback((Callback) new MethodInterceptorImpl()); MyClass my = (MyClass) enhancer.create(); my.print(); } private static class MethodInterceptorImpl implements MethodInterceptor { public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable { // log something System.out.println(method + " intercepted!"); proxy.invokeSuper(obj, args); return null; } } }
已有 1 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>
// 1. 分配一?ServerSocketChannel 文g描述W?
serverChannel = ServerSocketChannel.open();
// 2. ?ServerSocketChannel里获取一个对于的 socket
serverSocket = serverChannel.socket();
// 3. 生成一?Selector
selector = Selector.open();
// 4. ?socket l定到端口上
serverSocket.bind(new InetSocketAddress(iport));
// 5. serverChannel 未非bolck
serverChannel.configureBlocking(false);
// 6. 通过Selector注册ServerSocketChannel: 只能注册 accept
// 而SocketChannel可以注册CONNENCT,READ,WRITE ; register -> validOps
// 在各个子cdC?
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
while (true) {
try {
// 获得IO准备qA的channel数量
int n = selector.select();
// 没有channel准备qA,l箋执行
if (n == 0) {
continue;
}
// 用一个iteratorq回Selector的selectedkeys
Iterator it = selector.selectedKeys().iterator();
// 处理每一个SelectionKey
while (it.hasNext()) {
SelectionKey key = (SelectionKey) it.next();
// 判断是否有新的连接到?
if (key.isAcceptable()) {
// q回SelectionKey的ServerSocketChannel
ServerSocketChannel server = (ServerSocketChannel) key
.channel();
System.out.println("有连?);
SocketChannel channel = server.accept();
registerChannel(selector, channel, SelectionKey.OP_READ);
doWork(channel);
}
// 判断是否有数据在此channel里需要读?
if (key.isReadable()) {
processData(key);
}
}
// 删除 selectedkeys
it.remove();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
客户端：
//打开socket通道
SocketChannel socketChannel = SocketChannel.open();
//讄非阻塞方?
socketChannel.configureBlocking(false);
//打开选择?
Selector selector = Selector.open();
//注册q接到服务器socket动作
socketChannel.register(selector, SelectionKey.OP_CONNECT);
//q接
socketChannel.connect( new InetSocketAddress("localhost",9988));
Set<SelectionKey> selectkeySets;
SelectionKey selectionKey;
Iterator<SelectionKey> iterator;
//与服务器通信通道
SocketChannel clientChannel ;
while(true){
//选择一l徏Q其相应的通道已ؓI/O操作准备qA
//此方法执行处于阻塞模式的选择操作
selector.select(TIME_OUT);
//q回此选择器的已选择键集?
selectkeySets = selector.selectedKeys();
iterator = selectkeySets.iterator();
while(iterator.hasNext()){
selectionKey = iterator.next();
if (selectionKey.isConnectable()) {
clientChannel = (SocketChannel)selectionKey.channel();
// 判断此通道上是否正在进行连接操作?
// 完成套接字通道的连接过E?
if (clientChannel.isConnectionPending()) {//判断此通道上是否正在进行连接操?
clientChannel.finishConnect(); //完成套接字通道的连接过E?
}
clientChannel.register(selector, SelectionKey.OP_WRITE);
}else if (selectionKey.isReadable()) {
clientChannel = (SocketChannel)selectionKey.channel();
//缓冲区清空
receiveBuffer.clear();
//d服务器发送来的数据库到缓冲区
count = clientChannel.read(receiveBuffer);//count d到的字节?
if (count > 0) {
clientChannel.register(selector, SelectionKey.OP_WRITE);
}
}else if (selectionKey.isWritable()) {
sendBuffer.clear();
clientChannel = (SocketChannel)selectionKey.channel();
clientChannel.write(sendBuffer);
System.out.println("客户端向服务器发送数?"+sendText);
clientChannel.register(selector, SelectionKey.OP_READ);
}
}
}
已有 0 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>
// 创徏一个非d的server端socket Q用NIO
SocketAcceptor acceptor = new NioSocketAcceptor();
// 创徏接收数据的过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
// 讑֮q个qo器一行一?\r\n)的读数据
chain.addLast("myChin", new ProtocolCodecFilter(
new TextLineCodecFactory()));
//讑֮服务器端的消息处理器,一个SamplMinaServerHandler对象(自己实现)l承IoHandlerAdapter
acceptor.setHandler(new IoHandlerAdapter(){
//当一个客端端q结q入?
@Override
public void sessionOpened(IoSession session) throws Exception {
// TODO Auto-generated method stub
System.out.println("incomming client : "+session.getRemoteAddress());
}
//当一个客L关闭?
@Override
public void sessionClosed(IoSession session) throws Exception {
// TODO Auto-generated method stub
System.out.println("on client disconnect : "+session.getRemoteAddress());
}
//当客L发送的消息到达?
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
// TODO Auto-generated method stub
String s = (String)message;
System.out.println("收到客户端发来的消息:"+s);
//试消息回l客L
session.write(s+count);
count ++;
}
private int count =0;
});
//端口?
int bindPort= 9988;
//l定打开Q启动服务器
acceptor.bind(new InetSocketAddress(bindPort));
System.out.println("Mina Server is listing on:="+bindPort);
客户端：
// create TCP/IP connector
NioSocketConnector connector = new NioSocketConnector();
// 创徏接收数据的过滤器
DefaultIoFilterChainBuilder chain = connector.getFilterChain();
// 讑֮q个qo器将一行一?/r/n)的读取数?
chain.addLast("myChin", new ProtocolCodecFilter(
new TextLineCodecFactory()));
// 讑֮服务器端的消息处理器:一个SamplMinaServerHandler对象,
connector.setHandler(new IoHandlerAdapter(){
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
// 我们p定了服务器解析消息的规则是一行一行读?q里可转ؓString:
String s = (String) message;
// Write the received data back to remote peer
System.out.println("服务器发来的收到消息: " + s);
// 试消息回送给客户?
session.write(s);
}
@Override
public void sessionClosed(IoSession session) throws Exception {
// TODO Auto-generated method stub
System.out.println("one Clinet Disconnect !");
}
@Override
public void sessionOpened(IoSession session) throws Exception {
// TODO Auto-generated method stub
System.out.println("incomming client " + session.getRemoteAddress());
session.write("我来?.......");
}
});
// Set connect timeout.
connector.setConnectTimeout(30);
// q结到服务器:
ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",
9988));
// Wait for the connection attempt to be finished.
cf.awaitUninterruptibly();
cf.getSession().getCloseFuture().awaitUninterruptibly();
connector.dispose();
已有 0 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>
分区 用时间进行分?/p>
已有 0 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>
SocketChannel:Socket的替代类
Selector:为ServerSocketChannel监控接受qA事g,为SocketChannel监控q接qA,dl和写就l事?br>SelectionKey:代表ServerSocketChannel及SocketChannel向Selector注册事g句柄
向SocketChannel和ServerSocketChannel注册事g:
SelectionKey key=serverSocketChannel.register(selector,op)
Op的可选?br>对于ServerSocketChannel只有一个事?
(1)SelectionKye.OP_ACCEPT:接受q接qA事g,表示臛_有了一个客戯?服务器可以接受这个连?br>SocketChannel可能发生3U事?br>(1)SelectionKey.OP_CONNECT:q接׃ؓ事g,表示客户与服务器的连接已l成?br>(2)SelectionKey.OP_WRITE/OP_READ:写的qA事g,表示已经可以向输出流写数据了SocketChannel提供了接受和发送的Ҏ
可以使用:read(ByteBuffer)write(ByteBuffer)写入写出
ServerSocketChannelc?br>Ҏ:(PSl承qSelectableChannelcȝҎ)
(1)open()静态方法获取ServerSocketChannel对象.
(2)accept同ServerSocket,不过获取的是SocketChannel,Ҏ是否dq回nullq是d,值得注意的是acceptq回的SocketChannel是阻塞模式的使用configureBlocking更改模式
(3)socket() q回兌的ServerSocket
SocketChannelc?br>此类是Socketcȝ替代c?
Ҏ:(PSl承qSelectableChannelcȝҎ)
(1)open() open(SocketAddress)静态方法用来创建SocketChannel对象,W二个重写还会徏立于q程服务器的q接.
(2)socket()q回兌的Socket对象
(3)isConnected()是否建立q接
(4)isConnectionPending判断是否正在q行q程q接
(5)connect() 建立q程q接() Ҏ是否d而不?br>(6)finishConnect() 视图完成q程q接
(7)read()d数据(q个应该是接数据)
(8)write()写数?q个是发送数?
声明Q?/p>
public static int PORT = 8888; ServerSocketChannel serverChannel; ServerSocket serverSocket; Selector selector;
初始化：
// 1. 分配一?ServerSocketChannel 文g描述W? serverChannel = ServerSocketChannel.open(); // 2. ?ServerSocketChannel里获取一个对于的 socket serverSocket = serverChannel.socket(); // 3. 生成一?Selector selector = Selector.open(); // 4. ?socket l定到端口上 serverSocket.bind(new InetSocketAddress(iport)); // 5. serverChannel 未非bolck serverChannel.configureBlocking(false); // 6. 通过Selector注册ServerSocketChannel: 只能注册 accept // 而SocketChannel可以注册CONNENCT,READ,WRITE ; register -> validOps // 在各个子cdC? serverChannel.register(selector, SelectionKey.OP_ACCEPT);
开启服务：
while (true) {
try {
// 获得IO准备qA的channel数量
int n = selector.select();
// 没有channel准备qA,l箋执行
if (n == 0) {
continue;
}
// 用一个iteratorq回Selector的selectedkeys
Iterator it = selector.selectedKeys().iterator();
// 处理每一个SelectionKey
while (it.hasNext()) {
SelectionKey key = (SelectionKey) it.next();
// 判断是否有新的连接到?
if (key.isAcceptable()) {
// q回SelectionKey的ServerSocketChannel
ServerSocketChannel server = (ServerSocketChannel) key
.channel();
System.out.println("有连?);
SocketChannel channel = server.accept();
registerChannel(selector, channel, SelectionKey.OP_READ);
doWork(channel);
}
// 判断是否有数据在此channel里需要读?
if (key.isReadable()) {
processData(key);
}
}
// 删除 selectedkeys
it.remove();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
已有 0 人发表留aQ猛?>>q里<<-参与讨论
ITeye推荐
]]>