126 lines
2.7 KiB
JavaScript
126 lines
2.7 KiB
JavaScript
/**
|
|
* Sample React Native App
|
|
* https://github.com/facebook/react-native
|
|
* @flow
|
|
*/
|
|
|
|
import React, { Component } from 'react';
|
|
import {
|
|
AppRegistry,
|
|
ScrollView,
|
|
StyleSheet,
|
|
Text,
|
|
View
|
|
} from 'react-native';
|
|
|
|
global.Buffer = global.Buffer || require('buffer').Buffer;
|
|
|
|
var net = require('net');
|
|
|
|
function randomPort() {
|
|
return Math.random() * 60536 | 0 + 5000; // 60536-65536
|
|
}
|
|
|
|
var serverPort = randomPort();
|
|
|
|
class RctSockets extends Component {
|
|
constructor(props) {
|
|
super(props);
|
|
|
|
this.updateChatter = this.updateChatter.bind(this);
|
|
this.state = { chatter: [] };
|
|
}
|
|
|
|
updateChatter(msg) {
|
|
this.setState({
|
|
chatter: this.state.chatter.concat([msg])
|
|
});
|
|
}
|
|
|
|
componentDidMount() {
|
|
let server = net.createServer((socket) => {
|
|
this.updateChatter('server connected on ' + JSON.stringify(socket.address()));
|
|
|
|
socket.on('data', (data) => {
|
|
this.updateChatter('Server Received: ' + data);
|
|
socket.write('Echo server\r\n');
|
|
});
|
|
|
|
socket.on('error', (error) => {
|
|
this.updateChatter('error ' + error);
|
|
});
|
|
}).listen(serverPort, () => {
|
|
this.updateChatter('opened server on ' + JSON.stringify(server.address()));
|
|
});
|
|
|
|
server.on('error', (error) => {
|
|
this.updateChatter('error ' + error);
|
|
});
|
|
|
|
let client = net.createConnection(serverPort, () => {
|
|
this.updateChatter('opened client on ' + JSON.stringify(client.address()));
|
|
client.write('Hello, server! Love, Client.');
|
|
});
|
|
|
|
client.on('data', (data) => {
|
|
this.updateChatter('Client Received: ' + data);
|
|
|
|
this.client.destroy(); // kill client after server's response
|
|
this.server.close();
|
|
});
|
|
|
|
client.on('error', (error) => {
|
|
this.updateChatter('client error ' + error);
|
|
});
|
|
|
|
client.on('close', () => {
|
|
this.updateChatter('client close');
|
|
});
|
|
|
|
this.server = server;
|
|
this.client = client;
|
|
}
|
|
|
|
componentWillUnmount() {
|
|
this.server = null;
|
|
this.client = null;
|
|
}
|
|
|
|
render() {
|
|
return (
|
|
<View style={styles.container}>
|
|
<ScrollView>
|
|
{this.state.chatter.map((msg, index) => {
|
|
return (
|
|
<Text key={index} style={styles.welcome}>
|
|
{msg}
|
|
</Text>
|
|
);
|
|
})}
|
|
</ScrollView>
|
|
</View>
|
|
);
|
|
}
|
|
}
|
|
|
|
const styles = StyleSheet.create({
|
|
container: {
|
|
flex: 1,
|
|
justifyContent: 'center',
|
|
alignItems: 'center',
|
|
backgroundColor: '#F5FCFF',
|
|
},
|
|
welcome: {
|
|
fontSize: 20,
|
|
textAlign: 'center',
|
|
margin: 10,
|
|
},
|
|
instructions: {
|
|
textAlign: 'center',
|
|
color: '#333333',
|
|
marginBottom: 5,
|
|
},
|
|
});
|
|
|
|
AppRegistry.registerComponent('RctSockets', () => RctSockets);
|